org.apache.camel.component.jgroups
Class CamelJGroupsReceiver

java.lang.Object
  org.jgroups.ReceiverAdapter
      org.apache.camel.component.jgroups.CamelJGroupsReceiver

All Implemented Interfaces:

org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class CamelJGroupsReceiver
extends org.jgroups.ReceiverAdapter

Implementation of JGroups message receiver (org.jgroups.Receiver) wrapping incoming messages into Camel exchanges. Used by JGroupsConsumer.

Constructor Summary

CamelJGroupsReceiver(JGroupsEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

void	receive(org.jgroups.Message message)
void	viewAccepted(org.jgroups.View view)

Methods inherited from class org.jgroups.ReceiverAdapter

block, getState, setState, suspect, unblock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CamelJGroupsReceiver

public CamelJGroupsReceiver(JGroupsEndpoint endpoint,
                            org.apache.camel.Processor processor)

Method Detail

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

Overrides:

viewAccepted in class org.jgroups.ReceiverAdapter

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

Overrides:

receive in class org.jgroups.ReceiverAdapter