Package org.apache.unomi.router.core.route

Class ProfileImportFromSourceRouteBuilder

java.lang.Object

org.apache.camel.builder.BuilderSupport

org.apache.camel.builder.RouteBuilder

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

org.apache.unomi.router.core.route.ProfileImportFromSourceRouteBuilder

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

public class ProfileImportFromSourceRouteBuilder
extends RouterAbstractRouteBuilder

Created by amidani on 26/04/2017.

Field Summary

Fields inherited from class org.apache.unomi.router.core.route.RouterAbstractRouteBuilder

allowedEndpoints, configType, jacksonDataFormat, kafkaAutoCommit, kafkaConsumerCount, kafkaExportGroupId, kafkaExportTopic, kafkaHost, kafkaImportGroupId, kafkaImportTopic, kafkaPort, profileService

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

log

Constructor Summary

Constructors

Constructor	Description
ProfileImportFromSourceRouteBuilder(Map<String,String> kafkaProps, String configType)

Method Summary

Modifier and Type	Method	Description
void	configure()
void	setImportConfigurationList(List<ImportConfiguration> importConfigurationList)
void	setImportConfigurationService(ImportExportConfigurationService<ImportConfiguration> importConfigurationService)

Methods inherited from class org.apache.unomi.router.core.route.RouterAbstractRouteBuilder

getEndpointURI, setAllowedEndpoints, setJacksonDataFormat, setProfileService

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

addRoutes, addRoutesToCamelContext, checkInitialized, 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, jsonpath, jsonpath, 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

Constructor Detail

ProfileImportFromSourceRouteBuilder

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

Method Detail

configure

public void configure()
               throws Exception

Specified by:

configure in class org.apache.camel.builder.RouteBuilder

Throws:

Exception

setImportConfigurationList

public void setImportConfigurationList(List<ImportConfiguration> importConfigurationList)

setImportConfigurationService

public void setImportConfigurationService(ImportExportConfigurationService<ImportConfiguration> importConfigurationService)