public class NsqSynchronization
extends org.apache.camel.support.SynchronizationAdapter
Constructor and Description |
---|
NsqSynchronization(com.github.brainlag.nsq.NSQMessage nsqMessage,
int requeueInterval) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowHandover() |
void |
onComplete(org.apache.camel.Exchange exchange) |
void |
onFailure(org.apache.camel.Exchange exchange) |
public NsqSynchronization(com.github.brainlag.nsq.NSQMessage nsqMessage, int requeueInterval)
public void onComplete(org.apache.camel.Exchange exchange)
onComplete
in interface org.apache.camel.spi.Synchronization
onComplete
in class org.apache.camel.support.SynchronizationAdapter
public void onFailure(org.apache.camel.Exchange exchange)
onFailure
in interface org.apache.camel.spi.Synchronization
onFailure
in class org.apache.camel.support.SynchronizationAdapter
public boolean allowHandover()
allowHandover
in interface org.apache.camel.spi.SynchronizationVetoable
allowHandover
in class org.apache.camel.support.SynchronizationAdapter
Apache Camel