Package org.apache.activemq.artemis.api.core.jgroups

Class JGroupsReceiver

java.lang.Object

org.apache.activemq.artemis.api.core.jgroups.JGroupsReceiver

All Implemented Interfaces:

org.jgroups.Receiver

public class JGroupsReceiver
extends 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

Modifier and Type	Method	Description
void	receive(org.jgroups.Message msg)
byte[]	receiveBroadcast()
byte[]	receiveBroadcast(long time, 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 Details

JGroupsReceiver

public JGroupsReceiver()

Method Details

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.Receiver

receiveBroadcast

public byte[] receiveBroadcast()
                        throws Exception

Throws:

Exception

receiveBroadcast

public byte[] receiveBroadcast(long time,
 TimeUnit unit)
                        throws Exception

Throws:

Exception