Class ResequenceReifier

  • All Implemented Interfaces:
    org.apache.camel.spi.BeanRepository

    public class ResequenceReifier
    extends ProcessorReifier<org.apache.camel.model.ResequenceDefinition>
    • Constructor Detail

      • ResequenceReifier

        public ResequenceReifier​(org.apache.camel.Route route,
                                 org.apache.camel.model.ProcessorDefinition<?> definition)
    • Method Detail

      • createProcessor

        public org.apache.camel.Processor createProcessor()
                                                   throws Exception
        Description copied from class: ProcessorReifier
        Override this in definition class and implement logic to create the processor based on the definition model.
        Specified by:
        createProcessor in class ProcessorReifier<org.apache.camel.model.ResequenceDefinition>
        Throws:
        Exception
      • createBatchResequencer

        protected org.apache.camel.processor.Resequencer createBatchResequencer​(org.apache.camel.model.config.BatchResequencerConfig config)
                                                                         throws Exception
        Creates a batch Resequencer instance applying the given config.
        Parameters:
        config - batch resequencer configuration.
        Returns:
        the configured batch resequencer.
        Throws:
        Exception - can be thrown
      • createStreamResequencer

        protected org.apache.camel.processor.StreamResequencer createStreamResequencer​(org.apache.camel.model.config.StreamResequencerConfig config)
                                                                                throws Exception
        Creates a StreamResequencer instance applying the given config.
        Parameters:
        config - stream resequencer configuration.
        Returns:
        the configured stream resequencer.
        Throws:
        Exception - can be thrwon