public class ReceiverAdapter extends Object implements Receiver
Constructor and Description |
---|
ReceiverAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
block()
Called (usually by the FLUSH protocol), as an indication that the member should stop sending
messages.
|
void |
getState(OutputStream output)
Allows an application to write a state through a provided OutputStream.
|
void |
receive(Message msg)
Called when a message is received.
|
void |
receive(MessageBatch batch)
Called when a batch of messages is received
|
void |
setState(InputStream input)
Allows an application to read a state through a provided InputStream.
|
void |
suspect(Address 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 view)
Called when a change in membership has occurred.
|
public void receive(Message msg)
MessageListener
receive
in interface MessageListener
public void receive(MessageBatch batch)
MessageListener
receive
in interface MessageListener
public void getState(OutputStream output) throws Exception
StateListener
getState
in interface StateListener
output
- the OutputStreamException
- if the streaming fails, any exceptions should be thrown so that the state requester
can re-throw them and let the caller know what happenedOutputStream.close()
public void setState(InputStream input) throws Exception
StateListener
setState
in interface StateListener
input
- the InputStreamException
- if the streaming fails, any exceptions should be thrown so that the state requester
can catch them and thus know what happenedInputStream.close()
public void viewAccepted(View view)
MembershipListener
JChannel.connect(String)
returns.viewAccepted
in interface MembershipListener
public void suspect(Address mbr)
MembershipListener
suspect
in interface MembershipListener
public void block()
MembershipListener
MembershipListener.unblock()
. Note that block() is the equivalent
of reception of a BlockEvent in the pull mode.block
in interface MembershipListener
public void unblock()
MembershipListener
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 MembershipListener
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.