Class JGroupsReceiver

  • All Implemented Interfaces:
    org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

    public class JGroupsReceiver
    extends org.jgroups.ReceiverAdapter
    This class is used to receive messages from a JGroups channel. Incoming messages are put into a queue.
    • Constructor Summary

      Constructors 
      Constructor Description
      JGroupsReceiver()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void receive​(org.jgroups.Message msg)  
      byte[] receiveBroadcast()  
      byte[] receiveBroadcast​(long time, java.util.concurrent.TimeUnit unit)  
      • Methods inherited from class org.jgroups.ReceiverAdapter

        block, getState, setState, suspect, unblock, viewAccepted
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • JGroupsReceiver

        public JGroupsReceiver()
    • Method Detail

      • receive

        public void receive​(org.jgroups.Message msg)
        Specified by:
        receive in interface org.jgroups.MessageListener
        Overrides:
        receive in class org.jgroups.ReceiverAdapter
      • receiveBroadcast

        public byte[] receiveBroadcast()
                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • receiveBroadcast

        public byte[] receiveBroadcast​(long time,
                                       java.util.concurrent.TimeUnit unit)
                                throws java.lang.Exception
        Throws:
        java.lang.Exception