Package org.jgroups.demos

Class RelayDemoRpc

java.lang.Object

org.jgroups.demos.RelayDemoRpc

All Implemented Interfaces:

Receiver

public class RelayDemoRpc
extends Object
implements Receiver

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.

Field Summary

Fields

Modifier and Type	Field	Description
protected JChannel	ch
protected RpcDispatcher	disp
protected String	local_addr
protected static final long	RPC_TIMEOUT
protected View	view

Constructor Summary

Constructors

Constructor	Description
RelayDemoRpc()

Method Summary

Modifier and Type	Method	Description
static String	handleMessage(String msg, String sender)
static void	main(String[] args)
protected static Collection<String>	parseSiteMasters(String line)
(package private) static String	print(View view)
void	start(String props, String name)
void	viewAccepted(View new_view)	Called when a change in membership has occurred.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jgroups.Receiver

block, getState, receive, receive, setState, unblock

Field Details

ch

protected JChannel ch

disp

protected RpcDispatcher disp

local_addr

protected String local_addr

view

protected View view

RPC_TIMEOUT

protected static final long RPC_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

RelayDemoRpc

public RelayDemoRpc()

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

start

public void start(String props,
 String name)
           throws Exception

Throws:

Exception

parseSiteMasters

protected static Collection<String> parseSiteMasters(String line)

handleMessage

public static String handleMessage(String msg,
 String sender)

viewAccepted

public void viewAccepted(View new_view)

Description copied from interface: Receiver

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 when JChannel.connect(String) returns.

Specified by:

viewAccepted in interface Receiver

print

static String print(View view)