Package org.jgroups.protocols.relay

Class Bridge

java.lang.Object

org.jgroups.protocols.relay.Bridge

All Implemented Interfaces:

Receiver

public class Bridge
extends Object
implements Receiver

Class which joins the bridge cluster and send and receives messages to/from other sites. Also generates sitesUp()/sitesDown() notifications from view changes

Since:

5.2.17

Field Summary

Fields

Modifier and Type	Field	Description
protected final JChannel	channel
protected final String	cluster_name
protected final long	join_timeout
protected final Log	log
protected final Relayer3	rel
protected final RELAY	relay
protected View	view

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Bridge(JChannel ch, Relayer3 r, String cluster_name, String channel_name, AddressGenerator addr_generator)

Method Summary

Modifier and Type	Method	Description
protected static boolean	contains(List<Route> routes, Address addr)
void	receive(Message msg)	Called when a message is received.
protected static List<String>	removedRoutes(View old_view, View new_view)	Returns a list of routes that were in old_view, but are no longer in new_view
protected void	start()
protected void	stop()
String	toString()
void	viewAccepted(View new_view)	The view contains a list of SiteUUIDs.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.Receiver

block, getState, receive, setState, unblock

Field Details

channel

protected final JChannel channel

rel

protected final Relayer3 rel

relay

protected final RELAY relay

log

protected final Log log

cluster_name

protected final String cluster_name

view

protected View view

join_timeout

protected final long join_timeout

Constructor Details

Bridge

protected Bridge(JChannel ch,
 Relayer3 r,
 String cluster_name,
 String channel_name,
 AddressGenerator addr_generator)
          throws Exception

Throws:

Exception

Method Details

start

protected void start()
              throws Exception

Throws:

Exception

stop

protected void stop()

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)

The view contains a list of SiteUUIDs. Adjust the routing table based on the SiteUUIDs and site

Specified by:

viewAccepted in interface Receiver

toString

public String toString()

Overrides:

toString in class Object

contains

protected static boolean contains(List<Route> routes,
 Address addr)

removedRoutes

protected static List<String> removedRoutes(View old_view,
 View new_view)

Returns a list of routes that were in old_view, but are no longer in new_view