Package org.jgroups.demos

Class RelayDemo

java.lang.Object

org.jgroups.ReceiverAdapter

org.jgroups.demos.RelayDemo

All Implemented Interfaces:

MembershipListener, MessageListener, Receiver, StateListener

public class RelayDemo
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 RELAY2	relay
protected static java.lang.String	SITE_MASTERS

Constructor Summary

Constructors

Constructor	Description
RelayDemo()

Method Summary

Modifier and Type	Method	Description
protected void	eventLoop(JChannel ch)
protected static void	help()
static void	main(java.lang.String[] args)
protected static java.lang.String	print(View view)
protected java.lang.String	printTopology()
protected boolean	process(java.lang.String line)
void	receive(Message msg)	Called when a message is received.
protected void	start(java.lang.String props, java.lang.String name, boolean print_route_status, boolean nohup)
void	viewAccepted(View new_view)	Called when a change in membership has occurred.

Methods inherited from class org.jgroups.ReceiverAdapter

block, getState, receive, setState, suspect, unblock

Methods inherited from class java.lang.Object

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

Field Detail

SITE_MASTERS

protected static final java.lang.String SITE_MASTERS

See Also:

Constant Field Values

ch

protected JChannel ch

relay

protected RELAY2 relay

Constructor Detail

RelayDemo

public RelayDemo()

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: MessageListener

Called when a message is received.

Specified by:

receive in interface MessageListener

Overrides:

receive in class ReceiverAdapter

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

Specified by:

viewAccepted in interface MembershipListener

Overrides:

viewAccepted in class ReceiverAdapter

start

protected void start(java.lang.String props,
                     java.lang.String name,
                     boolean print_route_status,
                     boolean nohup)
              throws java.lang.Exception

Throws:

java.lang.Exception

eventLoop

protected void eventLoop(JChannel ch)

process

protected boolean process(java.lang.String line)

help

protected static void help()

printTopology

protected java.lang.String printTopology()

print

protected static java.lang.String print(View view)