Package org.jgroups.demos

Class RelayDemoRpc

java.lang.Object

org.jgroups.ReceiverAdapter

org.jgroups.demos.RelayDemoRpc

All Implemented Interfaces:

MembershipListener, MessageListener, Receiver

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 Address	local_addr
protected View	view

Constructor Summary

Constructors

Constructor	Description
RelayDemoRpc()

Method Summary

Modifier and Type	Method	Description
static String	handleMessage(String msg, Address sender)
static void	main(String[] args)
void	start(String props, String name)
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

Methods inherited from class java.lang.Object

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

Field Details

ch

protected JChannel ch

disp

protected RpcDispatcher disp

local_addr

protected Address local_addr

view

protected View view

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

handleMessage

public static String handleMessage(String msg,
 Address 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 or sending of messages 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 Channel.connect(String) returns.

Specified by:

viewAccepted in interface MembershipListener

Overrides:

viewAccepted in class ReceiverAdapter