Package org.apache.camel.component.nsq
Class NsqSynchronization
- java.lang.Object
-
- org.apache.camel.support.SynchronizationAdapter
-
- org.apache.camel.component.nsq.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 Summary
Constructors Constructor Description NsqSynchronization(com.github.brainlag.nsq.NSQMessage nsqMessage, int requeueInterval)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
allowHandover()
void
onComplete(org.apache.camel.Exchange exchange)
void
onFailure(org.apache.camel.Exchange exchange)
-
-
-
Method Detail
-
onComplete
public void onComplete(org.apache.camel.Exchange exchange)
- Specified by:
onComplete
in interfaceorg.apache.camel.spi.Synchronization
- Overrides:
onComplete
in classorg.apache.camel.support.SynchronizationAdapter
-
onFailure
public void onFailure(org.apache.camel.Exchange exchange)
- Specified by:
onFailure
in interfaceorg.apache.camel.spi.Synchronization
- Overrides:
onFailure
in classorg.apache.camel.support.SynchronizationAdapter
-
allowHandover
public boolean allowHandover()
- Specified by:
allowHandover
in interfaceorg.apache.camel.spi.SynchronizationVetoable
- Overrides:
allowHandover
in classorg.apache.camel.support.SynchronizationAdapter
-
-