org.jgroups.stack
public class RouterStub extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
RouterStub.ConnectionListener |
static class |
RouterStub.ConnectionStatus |
Constructor and Description |
---|
RouterStub(java.lang.String routerHost,
int routerPort,
java.net.InetAddress bindAddress,
RouterStub.ConnectionListener l)
Creates a stub for a remote Router object.
|
Modifier and Type | Method and Description |
---|---|
void |
checkConnection()
Checks whether the connection is open
|
void |
connect(java.lang.String group,
Address addr,
java.lang.String logical_name,
java.util.List<PhysicalAddress> phys_addrs)
Register this process with the router under
group . |
void |
destroy() |
void |
disconnect(java.lang.String group,
Address addr) |
void |
doConnect() |
RouterStub.ConnectionStatus |
getConnectionStatus() |
java.net.InetSocketAddress |
getGossipRouterAddress() |
java.io.DataInputStream |
getInputStream() |
java.util.List<PingData> |
getMembers(java.lang.String group) |
TUNNEL.StubReceiver |
getReceiver() |
java.net.Socket |
getSocket() |
int |
getSocketConnectionTimeout() |
int |
getSocketReadTimeout() |
void |
interrupt() |
boolean |
isConnected() |
boolean |
isTcpNoDelay() |
void |
join(long wait) |
void |
sendToAllMembers(java.lang.String group,
byte[] data,
int offset,
int length) |
void |
sendToMember(java.lang.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) |
java.lang.String |
toString() |
public RouterStub(java.lang.String routerHost, int routerPort, java.net.InetAddress bindAddress, RouterStub.ConnectionListener l)
routerHost
- The name of the router's hostrouterPort
- The router's portjava.net.SocketException
public void setReceiver(TUNNEL.StubReceiver receiver)
public TUNNEL.StubReceiver getReceiver()
public boolean isTcpNoDelay()
public void setTcpNoDelay(boolean tcp_nodelay)
public void interrupt()
public void join(long wait) throws java.lang.InterruptedException
java.lang.InterruptedException
public int getSocketConnectionTimeout()
public void setSocketConnectionTimeout(int sock_conn_timeout)
public int getSocketReadTimeout()
public void setSocketReadTimeout(int sock_read_timeout)
public boolean isConnected()
public RouterStub.ConnectionStatus getConnectionStatus()
public void connect(java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs) throws java.lang.Exception
group
.group
- The name of the group under which to registerjava.lang.Exception
public void doConnect() throws java.lang.Exception
java.lang.Exception
public void checkConnection()
public void disconnect(java.lang.String group, Address addr)
public void destroy()
public java.net.Socket getSocket()
public java.util.List<PingData> getMembers(java.lang.String group) throws java.lang.Exception
java.lang.Exception
public java.net.InetSocketAddress getGossipRouterAddress()
public java.lang.String toString()
toString
in class java.lang.Object
public void sendToAllMembers(java.lang.String group, byte[] data, int offset, int length) throws java.lang.Exception
java.lang.Exception
public void sendToMember(java.lang.String group, Address dest, byte[] data, int offset, int length) throws java.lang.Exception
java.lang.Exception
public java.io.DataInputStream getInputStream()
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.