public abstract class TcpBaseServer extends BaseServer
BaseServer.Reaper
Modifier and Type | Field and Description |
---|---|
protected int |
peer_addr_read_timeout |
client_bind_addr, client_bind_port, conn_expire_time, conn_listeners, conns, defer_client_binding, factory, linger, local_addr, log, reaper, reaperInterval, receiver, recv_buf_size, running, send_buf_size, sock_conn_timeout, sock_creation_lock, socket_factory, tcp_nodelay, time_service, use_peer_connections
Modifier | Constructor and Description |
---|---|
protected |
TcpBaseServer(ThreadFactory f,
SocketFactory sf) |
Modifier and Type | Method and Description |
---|---|
protected TcpConnection |
createConnection(Address dest)
Creates a new connection object to target dest, but doesn't yet connect it
|
int |
peerAddressReadTimeout() |
TcpBaseServer |
peerAddressReadTimeout(int timeout) |
addConnection, addConnectionListener, clearConnections, clientBindAddress, clientBindAddress, clientBindPort, clientBindPort, close, closeConnection, connectionClosed, connectionEstablished, connectionEstablishedTo, connExpireTime, connExpireTimeout, deferClientBinding, deferClientBinding, explanation, getConnection, getNumConnections, getNumOpenConnections, hasConnection, linger, linger, localAddress, localAddress, log, log, notifyConnectionClosed, notifyConnectionEstablished, printConnections, reaperInterval, reaperInterval, receive, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, running, send, send, sendBufferSize, sendBufferSize, sendToAll, sendToAll, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, start, stop, tcpNodelay, tcpNodelay, timeService, timeService, toString, usePeerConnections, usePeerConnections, validateArgs
protected TcpBaseServer(ThreadFactory f, SocketFactory sf)
protected TcpConnection createConnection(Address dest) throws Exception
BaseServer
createConnection
in class BaseServer
Exception
public int peerAddressReadTimeout()
public TcpBaseServer peerAddressReadTimeout(int timeout)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.