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