org.apache.catalina.tribes.transport
public abstract class ReceiverBase extends Object implements ChannelReceiver, ListenCallback, RxTaskPool.TaskCreator
Title:
Description:
Company:
Version: 1.0
| Field Summary | |
|---|---|
| protected static Log | log |
| static int | OPTION_DIRECT_BUFFER |
| Constructor Summary | |
|---|---|
| ReceiverBase() | |
| Method Summary | |
|---|---|
| protected int | bind(ServerSocket socket, int portstart, int retries)
recursive bind to find the next available port |
| boolean | doListen() |
| String | getAddress() |
| int | getAutoBind() |
| InetAddress | getBind() |
| boolean | getDirect() |
| ExecutorService | getExecutor() |
| String | getHost() |
| MessageListener | getListener() |
| int | getMaxTasks() |
| int | getMaxThreads() |
| MessageListener | getMessageListener()
getMessageListener
|
| int | getMinTasks() |
| int | getMinThreads() |
| boolean | getOoBInline() |
| int | getPort() |
| int | getRxBufSize() |
| int | getSecurePort() |
| long | getSelectorTimeout() |
| boolean | getSoKeepAlive() |
| boolean | getSoLingerOn() |
| int | getSoLingerTime() |
| boolean | getSoReuseAddress() |
| int | getSoTrafficClass() |
| RxTaskPool | getTaskPool() |
| String | getTcpListenAddress() |
| int | getTcpListenPort() |
| boolean | getTcpNoDelay() |
| long | getTcpSelectorTimeout() |
| int | getTcpThreadCount() |
| int | getTimeout() |
| int | getTxBufSize() |
| boolean | getUseBufferPool() |
| int | getWorkerThreadOptions() |
| void | heartbeat() |
| boolean | isListening() |
| void | messageDataReceived(ChannelMessage data) |
| void | setAddress(String host) |
| void | setAutoBind(int autoBind) |
| void | setBind(InetAddress bind) |
| void | setDirect(boolean direct) |
| void | setExecutor(ExecutorService executor) |
| void | setHost(String host) |
| void | setListen(boolean doListen) |
| void | setListener(MessageListener listener) |
| void | setLog(Log log) |
| void | setMaxTasks(int maxTasks) |
| void | setMaxThreads(int maxThreads) |
| void | setMessageListener(MessageListener listener)
setMessageListener
|
| void | setMinTasks(int minTasks) |
| void | setMinThreads(int minThreads) |
| void | setOoBInline(boolean ooBInline) |
| void | setPool(RxTaskPool pool) |
| void | setPort(int port) |
| void | setRxBufSize(int rxBufSize) |
| void | setSecurePort(int securePort) |
| void | setSelectorTimeout(long selTimeout) |
| void | setSoKeepAlive(boolean soKeepAlive) |
| void | setSoLingerOn(boolean soLingerOn) |
| void | setSoLingerTime(int soLingerTime) |
| void | setSoReuseAddress(boolean soReuseAddress) |
| void | setSoTrafficClass(int soTrafficClass) |
| void | setTcpListenAddress(String tcpListenHost) |
| void | setTcpListenPort(int tcpListenPort) |
| void | setTcpNoDelay(boolean tcpNoDelay) |
| void | setTcpSelectorTimeout(long selTimeout) |
| void | setTcpThreadCount(int tcpThreadCount) |
| void | setTimeout(int timeout) |
| void | setTxBufSize(int txBufSize) |
| void | setUseBufferPool(boolean useBufferPool) |
| void | start() |
| void | stop() |
Parameters: socket ServerSocket portstart int retries int
Returns: int
Throws: IOException
Returns: Returns the bind.
Returns: MessageListener
UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method
Returns: The port
UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method
Deprecated: use getAddress
Returns: String
Deprecated: use getPort
Returns: int
Deprecated: use getSelectorTimeout
Returns: long
Deprecated: use getMinThreads()/getMaxThreads()
Returns: int
Parameters: bind The bind to set.
Parameters: listener MessageListener
UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method
Deprecated: use setAddress
Parameters: tcpListenHost String
Deprecated: use setPort
Parameters: tcpListenPort int
Deprecated: use setSelectorTimeout
Parameters: selTimeout long
Deprecated: use setMaxThreads/setMinThreads
Parameters: tcpThreadCount int