com.fr.third.jgroups

接口 MessageListener

所有已知子接口:

Receiver

所有已知实现类:

Chat, Draw, FlowControlTest, JGroupsCacheReceiver, LargeState, MPerf, MPerfRpc, MyReceiver, PingPong, QuoteServer, ReceiverAdapter, RELAY.Receiver, RelayDemoRpc, Relayer.Bridge, ReplicatedHashMap, ReplicatedTree, RoundTrip, RoundTripMulticast, UnicastTest.MyReceiver, UnicastTestRpc, UPerf, UUPerf, ViewDemo, Whiteboard

public interface MessageListener

MessageListener allows a listener to be notified when a Message or a state transfer events arrives to a node.

MessageListener is often used by JGroups building blocks installed on top of a channel i.e RpcDispatcher and MessageDispatcher.

从以下版本开始:

2.0

作者:

Bela Ban, Vladimir Blagojevic

另请参阅:

RpcDispatcher, MessageDispatcher

方法概要

方法

限定符和类型	方法和说明
void	getState(java.io.OutputStream output) Allows an application to write a state through a provided OutputStream.
void	receive(Message msg) Called when a message is received.
void	setState(java.io.InputStream input) Allows an application to read a state through a provided InputStream.

方法详细资料

receive

void receive(Message msg)

Called when a message is received.

参数:

msg -

getState

void getState(java.io.OutputStream output)
              throws java.lang.Exception

Allows an application to write a state through a provided OutputStream. After the state has been written the OutputStream doesn't need to be closed as stream closing is automatically done when a calling thread returns from this callback.

参数:

output - the OutputStream

抛出:

java.lang.Exception - if the streaming fails, any exceptions should be thrown so that the state requester can re-throw them and let the caller know what happened

另请参阅:

OutputStream.close()

setState

void setState(java.io.InputStream input)
              throws java.lang.Exception

Allows an application to read a state through a provided InputStream. After the state has been read the InputStream doesn't need to be closed as stream closing is automatically done when a calling thread returns from this callback.

参数:

input - the InputStream

抛出:

java.lang.Exception - if the streaming fails, any exceptions should be thrown so that the state requester can catch them and thus know what happened

另请参阅:

InputStream.close()