Package org.jgroups.demos

Class RelayDemoRpc

java.lang.Object

org.jgroups.demos.RelayDemoRpc

All Implemented Interfaces:

Receiver

public class RelayDemoRpc
extends java.lang.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 java.lang.String	local_addr
protected static long	RPC_TIMEOUT
protected View	view

Constructor Summary

Constructors

Constructor	Description
RelayDemoRpc()

Method Summary

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)
(package private) static java.lang.String	print(View view)
void	receive(Message msg)	Called when a message is received.
void	start(java.lang.String props, java.lang.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, setState, unblock

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

Constructor Detail

RelayDemoRpc

public RelayDemoRpc()

Method Detail

main

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

Throws:

java.lang.Exception

receive

public void receive(Message msg)

Description copied from interface: Receiver

Called when a message is received.

Specified by:

receive in interface Receiver

Parameters:

msg - The message

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: 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 java.lang.String print(View view)