|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jgroups.ChannelListenerAdapter org.jgroups.blocks.PullPushAdapter
Receiver
instead, this class will be removed in JGroups 3.0
public class PullPushAdapter
Allows a client of Channel
to be notified when messages have been received
instead of having to actively poll the channel for new messages. Typically used in the
client role (receive()). As this class does not implement interface
Transport
, but uses it for receiving messages, an underlying object
has to be used to send messages (e.g. the channel on which an object of this class relies).
Multiple MembershipListeners can register with the PullPushAdapter; when a view is received, they will all be notified. There is one main message listener which sends and receives message. In addition, MessageListeners can register with a certain tag (identifier), and then send messages tagged with this identifier. When a message with such an identifier is received, the corresponding MessageListener will be looked up and the message dispatched to it. If no tag is found (default), the main MessageListener will receive the message.
Nested Class Summary | |
---|---|
static class |
PullPushAdapter.PullHeader
Deprecated. |
Field Summary | |
---|---|
protected MessageListener |
listener
Deprecated. |
protected java.util.HashMap |
listeners
Deprecated. |
protected Log |
log
Deprecated. |
protected java.util.List |
membership_listeners
Deprecated. |
protected java.lang.Thread |
receiver_thread
Deprecated. |
protected Transport |
transport
Deprecated. |
Constructor Summary | |
---|---|
PullPushAdapter(Transport transport)
Deprecated. |
|
PullPushAdapter(Transport transport,
MembershipListener ml)
Deprecated. |
|
PullPushAdapter(Transport transport,
MessageListener l)
Deprecated. |
|
PullPushAdapter(Transport transport,
MessageListener l,
MembershipListener ml)
Deprecated. |
|
PullPushAdapter(Transport transport,
MessageListener l,
MembershipListener ml,
boolean start)
Deprecated. |
Method Summary | |
---|---|
void |
addMembershipListener(MembershipListener l)
Deprecated. |
void |
channelClosed(Channel channel)
Deprecated. |
void |
channelConnected(Channel channel)
Deprecated. |
void |
channelDisconnected(Channel channel)
Deprecated. |
MessageListener |
getListener()
Deprecated. |
Transport |
getTransport()
Deprecated. |
protected void |
handleMessage(Message msg)
Deprecated. Check whether the message has an identifier. |
protected void |
notifyBlock()
Deprecated. |
protected void |
notifySuspect(Address suspected_mbr)
Deprecated. |
protected void |
notifyUnblock()
Deprecated. |
protected void |
notifyViewChange(View v)
Deprecated. |
void |
registerListener(java.io.Serializable identifier,
MessageListener l)
Deprecated. Sets a listener to messages with a given identifier. |
void |
removeMembershipListener(MembershipListener l)
Deprecated. |
void |
run()
Deprecated. Reentrant run(): message reception is serialized, then the listener is notified of the message reception |
void |
send(Message msg)
Deprecated. Sends a message with no identifier; listener member will get this message on the other group members. |
void |
send(java.io.Serializable identifier,
Message msg)
Deprecated. Sends a message to the group - listeners to this identifier will receive the messages. |
void |
setListener(MessageListener l)
Deprecated. |
void |
setMembershipListener(MembershipListener ml)
Deprecated. Use addMembershipListener(org.jgroups.MembershipListener) |
void |
start()
Deprecated. |
void |
stop()
Deprecated. |
void |
unregisterListener(java.io.Serializable identifier)
Deprecated. Removes a message listener to a given identifier from the message listeners map. |
Methods inherited from class org.jgroups.ChannelListenerAdapter |
---|
channelReconnected, channelShunned |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Transport transport
protected MessageListener listener
protected final java.util.List membership_listeners
protected java.lang.Thread receiver_thread
protected final java.util.HashMap listeners
protected final Log log
Constructor Detail |
---|
public PullPushAdapter(Transport transport)
public PullPushAdapter(Transport transport, MessageListener l)
public PullPushAdapter(Transport transport, MembershipListener ml)
public PullPushAdapter(Transport transport, MessageListener l, MembershipListener ml)
public PullPushAdapter(Transport transport, MessageListener l, MembershipListener ml, boolean start)
Method Detail |
---|
public Transport getTransport()
public final void start()
public void stop()
public void send(java.io.Serializable identifier, Message msg) throws java.lang.Exception
identifier
- the key that the proper listeners are listenting onmsg
- the Message to be sent
java.lang.Exception
registerListener(java.io.Serializable, org.jgroups.MessageListener)
public void send(Message msg) throws java.lang.Exception
msg
- the Message to be sent
java.lang.Exception
public final void setListener(MessageListener l)
public void registerListener(java.io.Serializable identifier, MessageListener l)
identifier
- - messages sent on the group with this object will be received by this listenerl
- - the listener that will get the messagepublic void unregisterListener(java.io.Serializable identifier)
identifier
- - the key to whom we do not want to listen any morepublic void setMembershipListener(MembershipListener ml)
addMembershipListener(org.jgroups.MembershipListener)
public final void addMembershipListener(MembershipListener l)
public void removeMembershipListener(MembershipListener l)
public void run()
run
in interface java.lang.Runnable
protected void handleMessage(Message msg)
protected void notifyViewChange(View v)
protected void notifySuspect(Address suspected_mbr)
protected void notifyBlock()
protected void notifyUnblock()
public void channelConnected(Channel channel)
channelConnected
in interface ChannelListener
channelConnected
in class ChannelListenerAdapter
public void channelDisconnected(Channel channel)
channelDisconnected
in interface ChannelListener
channelDisconnected
in class ChannelListenerAdapter
public void channelClosed(Channel channel)
channelClosed
in interface ChannelListener
channelClosed
in class ChannelListenerAdapter
public MessageListener getListener()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |