Class Splitter

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.AsyncProcessor, org.apache.camel.Navigate<org.apache.camel.Processor>, org.apache.camel.Processor, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.ErrorHandlerAware, org.apache.camel.spi.HasId, org.apache.camel.spi.IdAware, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.apache.camel.Traceable

    public class Splitter
    extends MulticastProcessor
    implements org.apache.camel.AsyncProcessor, org.apache.camel.Traceable
    Implements a dynamic Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint.
    • Constructor Detail

      • Splitter

        public Splitter​(org.apache.camel.CamelContext camelContext,
                        org.apache.camel.Route route,
                        org.apache.camel.Expression expression,
                        org.apache.camel.Processor destination,
                        org.apache.camel.AggregationStrategy aggregationStrategy,
                        boolean parallelProcessing,
                        ExecutorService executorService,
                        boolean shutdownExecutorService,
                        boolean streaming,
                        boolean stopOnException,
                        long timeout,
                        org.apache.camel.Processor onPrepare,
                        boolean useSubUnitOfWork,
                        boolean parallelAggregate)
      • Splitter

        public Splitter​(org.apache.camel.CamelContext camelContext,
                        org.apache.camel.Route route,
                        org.apache.camel.Expression expression,
                        org.apache.camel.Processor destination,
                        org.apache.camel.AggregationStrategy aggregationStrategy,
                        boolean parallelProcessing,
                        ExecutorService executorService,
                        boolean shutdownExecutorService,
                        boolean streaming,
                        boolean stopOnException,
                        long timeout,
                        org.apache.camel.Processor onPrepare,
                        boolean useSubUnitOfWork,
                        boolean parallelAggregate,
                        String delimiter)
      • Splitter

        public Splitter​(org.apache.camel.CamelContext camelContext,
                        org.apache.camel.Route route,
                        org.apache.camel.Expression expression,
                        org.apache.camel.Processor destination,
                        org.apache.camel.AggregationStrategy aggregationStrategy,
                        boolean parallelProcessing,
                        ExecutorService executorService,
                        boolean shutdownExecutorService,
                        boolean streaming,
                        boolean stopOnException,
                        long timeout,
                        org.apache.camel.Processor onPrepare,
                        boolean useSubUnitOfWork,
                        boolean parallelAggregate,
                        boolean stopOnAggregateException)
      • Splitter

        public Splitter​(org.apache.camel.CamelContext camelContext,
                        org.apache.camel.Route route,
                        org.apache.camel.Expression expression,
                        org.apache.camel.Processor destination,
                        org.apache.camel.AggregationStrategy aggregationStrategy,
                        boolean parallelProcessing,
                        ExecutorService executorService,
                        boolean shutdownExecutorService,
                        boolean streaming,
                        boolean stopOnException,
                        long timeout,
                        org.apache.camel.Processor onPrepare,
                        boolean useSubUnitOfWork,
                        boolean parallelAggregate,
                        boolean stopOnAggregateException,
                        String delimiter)