Package org.jgroups.demos

Class RelayDemo

java.lang.Object

org.jgroups.demos.RelayDemo

All Implemented Interfaces:

Receiver

public class RelayDemo
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 RELAY	relay
protected static final String	SENDTO
protected static final 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(String[] args)
protected String	printTopo(String line, String command, boolean refresh)
protected boolean	process(String line)
void	receive(Message msg)	Called when a message is received.
protected void	sendTo(String line)
protected void	start(String props, String name, boolean print_route_status, boolean nohup, boolean use_view_handler)
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 Details

SITE_MASTERS

protected static final String SITE_MASTERS

See Also:

• Constant Field Values

SENDTO

protected static final String SENDTO

See Also:

• Constant Field Values

ch

protected JChannel ch

relay

protected RELAY relay

Constructor Details

RelayDemo

public RelayDemo()

Method Details

main

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

Throws:

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

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

start

protected void start(String props,
 String name,
 boolean print_route_status,
 boolean nohup,
 boolean use_view_handler)
              throws Exception

Throws:

Exception

eventLoop

protected void eventLoop(JChannel ch)

process

protected boolean process(String line)

sendTo

protected void sendTo(String line)

printTopo

protected String printTopo(String line,
 String command,
 boolean refresh)

help

protected static void help()