Package 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
    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
    Description
    RouterAbstractRouteBuilder(Map<String,String> kafkaProps, String configType)
     

  • Method Summary

    Modifier and Type
    Method
    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, 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

  • Field Details

    • 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 Details

    • RouterAbstractRouteBuilder

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

  • Method Details

    • 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)