public class TCPConnectionMap extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
TCPConnectionMap.Receiver
Used for message reception.
|
class |
TCPConnectionMap.TCPConnection |
Modifier and Type | Field and Description |
---|---|
protected SocketFactory |
socket_factory |
Constructor and Description |
---|
TCPConnectionMap(String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
InetAddress bind_addr,
InetAddress external_addr,
int external_port,
int srv_port,
int max_port) |
TCPConnectionMap(String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
InetAddress bind_addr,
InetAddress external_addr,
int external_port,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time) |
TCPConnectionMap(String service_name,
ThreadFactory f,
TCPConnectionMap.Receiver r,
InetAddress bind_addr,
InetAddress external_addr,
int external_port,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time) |
protected SocketFactory socket_factory
public TCPConnectionMap(String service_name, ThreadFactory f, SocketFactory socket_factory, TCPConnectionMap.Receiver r, InetAddress bind_addr, InetAddress external_addr, int external_port, int srv_port, int max_port) throws Exception
Exception
public TCPConnectionMap(String service_name, ThreadFactory f, TCPConnectionMap.Receiver r, InetAddress bind_addr, InetAddress external_addr, int external_port, int srv_port, int max_port, long reaper_interval, long conn_expire_time) throws Exception
Exception
public TCPConnectionMap(String service_name, ThreadFactory f, SocketFactory socket_factory, TCPConnectionMap.Receiver r, InetAddress bind_addr, InetAddress external_addr, int external_port, int srv_port, int max_port, long reaper_interval, long conn_expire_time) throws Exception
Exception
public Address getLocalAddress()
public TCPConnectionMap.Receiver getReceiver()
public void setReceiver(TCPConnectionMap.Receiver receiver)
public SocketFactory getSocketFactory()
public void setSocketFactory(SocketFactory socket_factory)
public void addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<TCPConnectionMap.TCPConnection> l)
public void removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<TCPConnectionMap.TCPConnection> l)
public void receive(Address sender, byte[] data, int offset, int length)
public void send(Address dest, byte[] data, int offset, int length) throws Exception
Exception
public void stop()
public void setReceiveBufferSize(int recv_buf_size)
public void setSocketConnectionTimeout(int sock_conn_timeout)
public void setSendBufferSize(int send_buf_size)
public void setLinger(int linger)
public void setTcpNodelay(boolean tcp_nodelay)
public void setSendQueueSize(int send_queue_size)
public void setUseSendQueues(boolean use_send_queues)
public int getNumConnections()
public boolean connectionEstablishedTo(Address addr)
public String printConnections()
public void retainAll(Collection<Address> members)
public long getConnectionExpiryTimeout()
public int getSenderQueueSize()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.