Class JGroupsReceiver

  • All Implemented Interfaces:
    org.jgroups.Receiver

    public class JGroupsReceiver
    extends java.lang.Object
    implements org.jgroups.Receiver
    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 java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.jgroups.Receiver

        block, getState, receive, setState, unblock, viewAccepted
    • Constructor Detail

      • JGroupsReceiver

        public JGroupsReceiver()
    • Method Detail

      • receive

        public void receive​(org.jgroups.Message msg)
        Specified by:
        receive in interface org.jgroups.Receiver
      • 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