org.apache.unomi.router.core.route

Class RouterAbstractRouteBuilder

java.lang.Object

org.apache.camel.builder.BuilderSupport

org.apache.camel.builder.RouteBuilder

org.apache.unomi.router.core.route.RouterAbstractRouteBuilder

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

Direct Known Subclasses:

ProfileExportCollectRouteBuilder, ProfileExportProducerRouteBuilder, ProfileImportFromSourceRouteBuilder, ProfileImportOneShotRouteBuilder, ProfileImportToUnomiRouteBuilder

public abstract class RouterAbstractRouteBuilder
extends org.apache.camel.builder.RouteBuilder

Created by amidani on 13/06/2017.

Field Summary

Fields

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

Fields inherited from class org.apache.camel.builder.RouteBuilder

log

Constructor Summary

Constructors

Constructor and Description
RouterAbstractRouteBuilder(Map<String,String> kafkaProps, String configType)

Method Summary

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)

Methods inherited from class org.apache.camel.builder.RouteBuilder

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

Methods inherited from class org.apache.camel.builder.BuilderSupport

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

jacksonDataFormat

protected org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat

kafkaHost

protected String kafkaHost

kafkaPort

protected String kafkaPort

kafkaImportTopic

protected String kafkaImportTopic

kafkaExportTopic

protected String kafkaExportTopic

kafkaImportGroupId

protected String kafkaImportGroupId

kafkaExportGroupId

protected String kafkaExportGroupId

kafkaConsumerCount

protected String kafkaConsumerCount

kafkaAutoCommit

protected String kafkaAutoCommit

configType

protected String configType

allowedEndpoints

protected String allowedEndpoints

profileService

protected ProfileService profileService

Constructor Detail

RouterAbstractRouteBuilder

public RouterAbstractRouteBuilder(Map<String,String> kafkaProps,
                                  String configType)

Method Detail

getEndpointURI

public Object getEndpointURI(String direction,
                             String operationDepositBuffer)

setJacksonDataFormat

public void setJacksonDataFormat(org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat)

setAllowedEndpoints

public void setAllowedEndpoints(String allowedEndpoints)

setProfileService

public void setProfileService(ProfileService profileService)