public abstract class RouterAbstractRouteBuilder
extends org.apache.camel.builder.RouteBuilder
Modifier and Type | Field and Description |
---|---|
protected String |
allowedEndpoints |
protected String |
configType |
protected org.apache.camel.component.jackson.JacksonDataFormat |
jacksonDataFormat |
protected String |
kafkaAutoCommit |
protected String |
kafkaConsumerCount |
protected String |
kafkaExportGroupId |
protected String |
kafkaExportTopic |
protected String |
kafkaHost |
protected String |
kafkaImportGroupId |
protected String |
kafkaImportTopic |
protected String |
kafkaPort |
protected ProfileService |
profileService |
Constructor and Description |
---|
RouterAbstractRouteBuilder(Map<String,String> kafkaProps,
String configType) |
Modifier and Type | Method and Description |
---|---|
Object |
getEndpointURI(String direction,
String operationDepositBuffer) |
void |
setAllowedEndpoints(String allowedEndpoints) |
void |
setJacksonDataFormat(org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat) |
void |
setProfileService(ProfileService profileService) |
addRoutes, addRoutesToCamelContext, checkInitialized, configure, configureRest, configureRests, configureRoute, configureRoutes, createContainer, errorHandler, from, from, from, from, fromF, getContext, getRestCollection, getRestConfigurations, getRouteCollection, includeRoutes, intercept, interceptFrom, interceptFrom, interceptSendToEndpoint, onCompletion, onException, onException, populateRests, populateRoutes, populateTransformers, populateValidators, propertyInject, rest, rest, restConfiguration, restConfiguration, setErrorHandlerBuilder, setRestCollection, setRouteCollection, toString, transformer, validator
bean, bean, bean, bean, body, body, bodyAs, constant, createErrorHandlerBuilder, deadLetterChannel, deadLetterChannel, defaultErrorHandler, endpoint, endpoint, endpoints, endpoints, exceptionMessage, exchangeProperty, faultBody, faultBodyAs, getErrorHandlerBuilder, header, language, loggingErrorHandler, loggingErrorHandler, loggingErrorHandler, loggingErrorHandler, method, method, method, method, noErrorHandler, outBody, outBody, property, regexReplaceAll, regexReplaceAll, sendTo, setContext, setContext, simple, simple, simpleF, simpleF, systemProperty, systemProperty, xpath, xpath
protected org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat
protected String kafkaHost
protected String kafkaPort
protected String kafkaImportTopic
protected String kafkaExportTopic
protected String kafkaImportGroupId
protected String kafkaExportGroupId
protected String kafkaConsumerCount
protected String kafkaAutoCommit
protected String configType
protected String allowedEndpoints
protected ProfileService profileService
public void setJacksonDataFormat(org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat)
public void setAllowedEndpoints(String allowedEndpoints)
public void setProfileService(ProfileService profileService)
Copyright © 2014–2023 Apache Software Foundation. All rights reserved.