Class NsqSynchronization

  • All Implemented Interfaces:
    org.apache.camel.Ordered, org.apache.camel.spi.Synchronization, org.apache.camel.spi.SynchronizationRouteAware, org.apache.camel.spi.SynchronizationVetoable

    public class NsqSynchronization
    extends org.apache.camel.support.SynchronizationAdapter
    • Constructor Detail

      • NsqSynchronization

        public NsqSynchronization​(com.github.brainlag.nsq.NSQMessage nsqMessage,
                                  int requeueInterval)
    • Method Detail

      • onComplete

        public void onComplete​(org.apache.camel.Exchange exchange)
        Specified by:
        onComplete in interface org.apache.camel.spi.Synchronization
        Overrides:
        onComplete in class org.apache.camel.support.SynchronizationAdapter
      • onFailure

        public void onFailure​(org.apache.camel.Exchange exchange)
        Specified by:
        onFailure in interface org.apache.camel.spi.Synchronization
        Overrides:
        onFailure in class org.apache.camel.support.SynchronizationAdapter
      • allowHandover

        public boolean allowHandover()
        Specified by:
        allowHandover in interface org.apache.camel.spi.SynchronizationVetoable
        Overrides:
        allowHandover in class org.apache.camel.support.SynchronizationAdapter