public class JGroupsConsumer
extends org.apache.camel.impl.DefaultConsumer
org.jgroups.Channel
). Received messages
(org.jgroups.Message
) are routed to Camel as the body of Exchange
.Constructor and Description |
---|
JGroupsConsumer(JGroupsEndpoint endpoint,
org.apache.camel.Processor processor,
org.jgroups.Channel channel,
String clusterName) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JGroupsConsumer(JGroupsEndpoint endpoint, org.apache.camel.Processor processor, org.jgroups.Channel channel, String clusterName)
Apache Camel