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

Class ProfileExportProducerRouteBuilder

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.ProfileExportProducerRouteBuilder

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

public class ProfileExportProducerRouteBuilder
extends RouterAbstractRouteBuilder

Created by amidani on 28/06/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
ProfileExportProducerRouteBuilder(Map<String,String> kafkaProps, String configType)

Method Summary

Modifier and Type	Method	Description
void	configure()
void	setExportRouteCompletionProcessor(ExportRouteCompletionProcessor exportRouteCompletionProcessor)
void	setProfileExportService(ProfileExportService profileExportService)

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

ProfileExportProducerRouteBuilder

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

Method Detail

setProfileExportService

public void setProfileExportService(ProfileExportService profileExportService)

configure

public void configure()
               throws Exception

Specified by:

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

Throws:

Exception

setExportRouteCompletionProcessor

public void setExportRouteCompletionProcessor(ExportRouteCompletionProcessor exportRouteCompletionProcessor)