public class RouterStub extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
RouterStub.ConnectionListener |
static class |
RouterStub.ConnectionStatus |
Constructor and Description |
---|
RouterStub(String routerHost,
int routerPort,
InetAddress bindAddress,
RouterStub.ConnectionListener l)
Creates a stub for a remote Router object.
|
public RouterStub(String routerHost, int routerPort, InetAddress bindAddress, RouterStub.ConnectionListener l)
routerHost
- The name of the router's hostrouterPort
- The router's portSocketException
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 InterruptedException
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(String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs) throws Exception
group
.group
- The name of the group under which to registerException
public void checkConnection()
public void destroy()
public Socket getSocket()
public InetSocketAddress getGossipRouterAddress()
public void sendToAllMembers(String group, byte[] data, int offset, int length) throws Exception
Exception
public void sendToMember(String group, Address dest, byte[] data, int offset, int length) throws Exception
Exception
public DataInputStream getInputStream()
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.