Package org.jgroups.demos
Class RelayDemoRpc
- java.lang.Object
-
- org.jgroups.ReceiverAdapter
-
- org.jgroups.demos.RelayDemoRpc
-
- All Implemented Interfaces:
MembershipListener
,MessageListener
,Receiver
,StateListener
public class RelayDemoRpc extends ReceiverAdapter
Demos RELAY. Create 2 *separate* clusters with RELAY as top protocol. Each RELAY has bridge_props="tcp.xml" (tcp.xml needs to be present). Then start 2 instances in the first cluster and 2 instances in the second cluster. They should find each other, and typing in a window should send the text to everyone, plus we should get 4 responses.- Author:
- Bela Ban
-
-
Field Summary
Fields Modifier and Type Field Description protected JChannel
ch
protected RpcDispatcher
disp
protected java.lang.String
local_addr
protected static long
RPC_TIMEOUT
protected View
view
-
Constructor Summary
Constructors Constructor Description RelayDemoRpc()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static java.lang.String
handleMessage(java.lang.String msg, java.lang.String sender)
static void
main(java.lang.String[] args)
protected static java.util.Collection<java.lang.String>
parseSiteMasters(java.lang.String line)
void
start(java.lang.String props, java.lang.String name)
void
viewAccepted(View new_view)
Called when a change in membership has occurred.
-
-
-
Field Detail
-
ch
protected JChannel ch
-
disp
protected RpcDispatcher disp
-
local_addr
protected java.lang.String local_addr
-
view
protected View view
-
RPC_TIMEOUT
protected static final long RPC_TIMEOUT
- See Also:
- Constant Field Values
-
-
Method Detail
-
main
public static void main(java.lang.String[] args) throws java.lang.Exception
- Throws:
java.lang.Exception
-
start
public void start(java.lang.String props, java.lang.String name) throws java.lang.Exception
- Throws:
java.lang.Exception
-
parseSiteMasters
protected static java.util.Collection<java.lang.String> parseSiteMasters(java.lang.String line)
-
handleMessage
public static java.lang.String handleMessage(java.lang.String msg, java.lang.String sender)
-
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
-
-