public class CamelJGroupsReceiver
extends org.jgroups.ReceiverAdapter
org.jgroups.Receiver
) wrapping incoming messages into Camel
exchanges. Used by JGroupsConsumer
.Constructor and Description |
---|
CamelJGroupsReceiver(JGroupsEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
void |
receive(org.jgroups.Message message) |
void |
viewAccepted(org.jgroups.View view) |
public CamelJGroupsReceiver(JGroupsEndpoint endpoint, org.apache.camel.Processor processor)
public void viewAccepted(org.jgroups.View view)
viewAccepted
in interface org.jgroups.MembershipListener
viewAccepted
in class org.jgroups.ReceiverAdapter
public void receive(org.jgroups.Message message)
receive
in interface org.jgroups.MessageListener
receive
in class org.jgroups.ReceiverAdapter
Apache Camel