|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jgroups.ExtendedReceiverAdapter
public class ExtendedReceiverAdapter
Constructor Summary | |
---|---|
ExtendedReceiverAdapter()
|
Method Summary | |
---|---|
void |
block()
Called (usually by the FLUSH protocol), as an indication that the member should stop sending messages. |
byte[] |
getState()
Answers the group state; e.g., when joining. |
void |
getState(java.io.OutputStream ostream)
Allows an application to write a state through a provided OutputStream. |
byte[] |
getState(java.lang.String state_id)
Allows an application to provide a partial state as a byte array |
void |
getState(java.lang.String state_id,
java.io.OutputStream ostream)
Allows an application to write a partial state through a provided OutputStream. |
void |
receive(Message msg)
Called when a message is received. |
void |
setState(byte[] state)
Sets the group state; e.g., when joining. |
void |
setState(java.io.InputStream istream)
Allows an application to read a state through a provided InputStream. |
void |
setState(java.lang.String state_id,
byte[] state)
Allows an application to read a partial state indicated by state_id from a given state byte array parameter. |
void |
setState(java.lang.String state_id,
java.io.InputStream istream)
Allows an application to read a partial state through a provided InputStream. |
void |
suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed, but has not yet been excluded. |
void |
unblock()
Called after the FLUSH protocol has unblocked previously blocked senders, and messages can be sent again. |
void |
viewAccepted(View new_view)
Called when a change in membership has occurred. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ExtendedReceiverAdapter()
Method Detail |
---|
public byte[] getState(java.lang.String state_id)
ExtendedMessageListener
getState
in interface ExtendedMessageListener
state_id
- id of the partial state requested
public void setState(java.lang.String state_id, byte[] state)
ExtendedMessageListener
setState
in interface ExtendedMessageListener
state_id
- id of the partial state requestedstate
- partial state for the given state_idpublic void receive(Message msg)
MessageListener
receive
in interface MessageListener
public byte[] getState()
MessageListener
getState
in interface MessageListener
public void setState(byte[] state)
MessageListener
setState
in interface MessageListener
public void viewAccepted(View new_view)
MembershipListener
Channel.connect(String)
returns.
viewAccepted
in interface MembershipListener
public void suspect(Address suspected_mbr)
MembershipListener
suspect
in interface MembershipListener
public void block()
MembershipListener
ExtendedMembershipListener.unblock()
.
Note that block() is the equivalent of reception of a BlockEvent in the pull mode.
block
in interface MembershipListener
public void unblock()
ExtendedMembershipListener
Note that during new view installation we provide guarantee that unblock invocation strictly follows view installation at some node A belonging to that view . However, some other message M may squeeze in between view and unblock callbacks. For more details see https://jira.jboss.org/jira/browse/JGRP-986
unblock
in interface ExtendedMembershipListener
public void getState(java.io.OutputStream ostream)
ExtendedMessageListener
getState
in interface ExtendedMessageListener
ostream
- the OutputStreamOutputStream.close()
public void getState(java.lang.String state_id, java.io.OutputStream ostream)
ExtendedMessageListener
getState
in interface ExtendedMessageListener
state_id
- id of the partial state requestedostream
- the OutputStreamOutputStream.close()
public void setState(java.io.InputStream istream)
ExtendedMessageListener
setState
in interface ExtendedMessageListener
istream
- the InputStreamInputStream.close()
public void setState(java.lang.String state_id, java.io.InputStream istream)
ExtendedMessageListener
setState
in interface ExtendedMessageListener
state_id
- id of the partial state requestedistream
- the InputStreamInputStream.close()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |