Class JGroupsReceiver
- java.lang.Object
-
- org.apache.activemq.artemis.api.core.jgroups.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)
-
-
-
Method Detail
-
receive
public void receive(org.jgroups.Message msg)
- Specified by:
receive
in interfaceorg.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
-
-