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

Class ProfileImportOneShotRouteBuilder

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

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

public class ProfileImportOneShotRouteBuilder
extends RouterAbstractRouteBuilder

Created by amidani on 22/05/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
ProfileImportOneShotRouteBuilder(Map<String,String> kafkaProps, String configType)

Method Summary

Modifier and Type	Method	Description
void	configure()
void	setImportConfigByFileNameProcessor(ImportConfigByFileNameProcessor importConfigByFileNameProcessor)
void	setUploadDir(String uploadDir)

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

ProfileImportOneShotRouteBuilder

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

setImportConfigByFileNameProcessor

public void setImportConfigByFileNameProcessor(ImportConfigByFileNameProcessor importConfigByFileNameProcessor)

setUploadDir

public void setUploadDir(String uploadDir)