org.jgroups
Class ReceiverAdapter
java.lang.Object
org.jgroups.ReceiverAdapter
- MembershipListener, MessageListener, Receiver
public class ReceiverAdapter
extends java.lang.Object
$Id: ReceiverAdapter.java,v 1.1 2005/11/08 10:43:38 belaban Exp $ void | block() - Called whenever the member needs to stop sending messages.
|
byte[] | getState() - Answers the group state; e.g., when joining.
|
void | receive(Message msg) - Called when a message is received.
|
void | setState(byte[] state) - Sets the group state; e.g., when joining.
|
void | suspect(Address suspected_mbr) - Called whenever a member is suspected of having crashed,
but has not yet been excluded.
|
void | viewAccepted(View new_view) - Called when a change in membership has occurred.
|
block
public void block()
Called whenever the member needs to stop sending messages.
When the next view is received (viewAccepted()), the member can resume sending
messages. If a member does not comply, the message(s) sent between a block()
and a matching viewAccepted() callback will probably be delivered in the next view.
The block() callback is only needed by the Virtual Synchrony suite of protocols
(FLUSH protocol)3.2, otherwise it will never be invoked.
- block in interface MembershipListener
getState
public byte[] getState()
Answers the group state; e.g., when joining.
- getState in interface MessageListener
setState
public void setState(byte[] state)
Sets the group state; e.g., when joining.
- setState in interface MessageListener
suspect
public void suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed,
but has not yet been excluded.
- suspect in interface MembershipListener
viewAccepted
public void viewAccepted(View new_view)
Called when a change in membership has occurred.
No long running actions should be done in this callback.
If some long running action needs to be performed, it should be done in a separate thread.
- viewAccepted in interface MembershipListener
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.