Package org.jgroups.demos
Class Chat
- java.lang.Object
-
- org.jgroups.ReceiverAdapter
-
- org.jgroups.demos.Chat
-
- All Implemented Interfaces:
MembershipListener
,MessageListener
,Receiver
,StateListener
public class Chat extends ReceiverAdapter
-
-
Constructor Summary
Constructors Constructor Description Chat()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected static void
help()
static void
main(java.lang.String[] args)
void
receive(Message msg)
Called when a message is received.void
start(JChannel ch)
Method called from other app, injecting channelvoid
viewAccepted(View new_view)
Called when a change in membership has occurred.
-
-
-
Field Detail
-
channel
protected JChannel channel
-
CLUSTER
protected static final java.lang.String CLUSTER
- See Also:
- Constant Field Values
-
-
Method Detail
-
viewAccepted
public void viewAccepted(View new_view)
Description copied from interface:MembershipListener
Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread. Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens whenJChannel.connect(String)
returns.- Specified by:
viewAccepted
in interfaceMembershipListener
- Overrides:
viewAccepted
in classReceiverAdapter
-
receive
public void receive(Message msg)
Description copied from interface:MessageListener
Called when a message is received.- Specified by:
receive
in interfaceMessageListener
- Overrides:
receive
in classReceiverAdapter
-
start
public void start(JChannel ch) throws java.lang.Exception
Method called from other app, injecting channel- Throws:
java.lang.Exception
-
main
public static void main(java.lang.String[] args) throws java.lang.Exception
- Throws:
java.lang.Exception
-
help
protected static void help()
-
-