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

Class ProfileImportToUnomiRouteBuilder

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

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

public class ProfileImportToUnomiRouteBuilder
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
ProfileImportToUnomiRouteBuilder(Map<String,String> kafkaProps, String configType)

Method Summary

Modifier and Type	Method	Description
void	configure()
void	setImportRouteCompletionProcessor(ImportRouteCompletionProcessor importRouteCompletionProcessor)
void	setUnomiStorageProcessor(UnomiStorageProcessor unomiStorageProcessor)

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

ProfileImportToUnomiRouteBuilder

public ProfileImportToUnomiRouteBuilder(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

setUnomiStorageProcessor

public void setUnomiStorageProcessor(UnomiStorageProcessor unomiStorageProcessor)

setImportRouteCompletionProcessor

public void setImportRouteCompletionProcessor(ImportRouteCompletionProcessor importRouteCompletionProcessor)