Package org.jgroups.stack

Class RouterStub

java.lang.Object

org.jgroups.stack.RouterStub

public class RouterStub
extends Object

Client stub that talks to a remote GossipRouter

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RouterStub.ConnectionListener
static enum	RouterStub.ConnectionStatus

Constructor Summary

Constructors

Constructor	Description
RouterStub(String routerHost, int routerPort, InetAddress bindAddress, RouterStub.ConnectionListener l)	Creates a stub for a remote Router object.

Method Summary

Modifier and Type	Method	Description
void	checkConnection()	Checks whether the connection is open
void	connect(String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs)	Register this process with the router under group.
void	destroy()
void	disconnect(String group, Address addr)
void	doConnect()
RouterStub.ConnectionStatus	getConnectionStatus()
InetSocketAddress	getGossipRouterAddress()
DataInputStream	getInputStream()
List<PingData>	getMembers(String group)
TUNNEL.StubReceiver	getReceiver()
Socket	getSocket()
int	getSocketConnectionTimeout()
int	getSocketReadTimeout()
void	interrupt()
boolean	isConnected()
boolean	isTcpNoDelay()
void	join(long wait)
void	sendToAllMembers(String group, byte[] data, int offset, int length)
void	sendToMember(String group, Address dest, byte[] data, int offset, int length)
void	setReceiver(TUNNEL.StubReceiver receiver)
void	setSocketConnectionTimeout(int sock_conn_timeout)
void	setSocketReadTimeout(int sock_read_timeout)
void	setTcpNoDelay(boolean tcp_nodelay)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

RouterStub

public RouterStub(String routerHost,
 int routerPort,
 InetAddress bindAddress,
 RouterStub.ConnectionListener l)

Creates a stub for a remote Router object.

Parameters:

routerHost - The name of the router's host

routerPort - The router's port

Throws:

SocketException

Method Details

setReceiver

public void setReceiver(TUNNEL.StubReceiver receiver)

getReceiver

public TUNNEL.StubReceiver getReceiver()

isTcpNoDelay

public boolean isTcpNoDelay()

setTcpNoDelay

public void setTcpNoDelay(boolean tcp_nodelay)

interrupt

public void interrupt()

join

public void join(long wait)
          throws InterruptedException

Throws:

InterruptedException

getSocketConnectionTimeout

public int getSocketConnectionTimeout()

setSocketConnectionTimeout

public void setSocketConnectionTimeout(int sock_conn_timeout)

getSocketReadTimeout

public int getSocketReadTimeout()

setSocketReadTimeout

public void setSocketReadTimeout(int sock_read_timeout)

isConnected

public boolean isConnected()

getConnectionStatus

public RouterStub.ConnectionStatus getConnectionStatus()

connect

public void connect(String group,
 Address addr,
 String logical_name,
 List<PhysicalAddress> phys_addrs)
             throws Exception

Register this process with the router under group.

Parameters:

group - The name of the group under which to register

Throws:

Exception

doConnect

public void doConnect()
               throws Exception

Throws:

Exception

checkConnection

public void checkConnection()

Checks whether the connection is open

disconnect

public void disconnect(String group,
 Address addr)

destroy

public void destroy()

getSocket

public Socket getSocket()

getMembers

public List<PingData> getMembers(String group)
                          throws Exception

Throws:

Exception

getGossipRouterAddress

public InetSocketAddress getGossipRouterAddress()

toString

public String toString()

Overrides:

toString in class Object

sendToAllMembers

public void sendToAllMembers(String group,
 byte[] data,
 int offset,
 int length)
                      throws Exception

Throws:

Exception

sendToMember

public void sendToMember(String group,
 Address dest,
 byte[] data,
 int offset,
 int length)
                  throws Exception

Throws:

Exception

getInputStream

public DataInputStream getInputStream()