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

Class RouterAbstractRouteBuilder

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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

    • Field Detail

      • 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

    • Constructor Detail

      • RouterAbstractRouteBuilder

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

    • Method Detail

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