org.apache.catalina.tribes.transport.bio
public class BioReceiver extends ReceiverBase implements java.lang.Runnable, ChannelReceiver, ListenCallback
| Modifier and Type | Field and Description |
|---|---|
protected static Log |
log |
protected java.net.ServerSocket |
serverSocket |
OPTION_DIRECT_BUFFER| Constructor and Description |
|---|
BioReceiver() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
bind() |
AbstractRxTask |
createRxTask() |
protected BioReplicationTask |
getReplicationThread() |
void |
listen() |
void |
run() |
void |
start()
Start listening for incoming messages on the host/port
|
void |
stop()
Stop listening for messages
|
bind, doListen, getAddress, getAutoBind, getBind, getDirect, getExecutor, getHost, getListener, getMaxTasks, getMaxThreads, getMessageListener, getMinTasks, getMinThreads, getOoBInline, getPort, getRxBufSize, getSecurePort, getSelectorTimeout, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTaskPool, getTcpListenAddress, getTcpListenPort, getTcpNoDelay, getTcpSelectorTimeout, getTcpThreadCount, getTimeout, getTxBufSize, getUseBufferPool, getWorkerThreadOptions, heartbeat, isListening, messageDataReceived, setAddress, setAutoBind, setBind, setDirect, setExecutor, setHost, setListen, setListener, setLog, setMaxTasks, setMaxThreads, setMessageListener, setMinTasks, setMinThreads, setOoBInline, setPool, setPort, setRxBufSize, setSecurePort, setSelectorTimeout, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpListenAddress, setTcpListenPort, setTcpNoDelay, setTcpSelectorTimeout, setTcpThreadCount, setTimeout, setTxBufSize, setUseBufferPoolclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetHost, getMessageListener, getPort, getSecurePort, setMessageListenermessageDataReceivedprotected static Log log
protected java.net.ServerSocket serverSocket
public void start()
throws java.io.IOException
ChannelReceiverstart in interface ChannelReceiverstart in class ReceiverBasejava.io.IOExceptionpublic AbstractRxTask createRxTask()
createRxTask in interface RxTaskPool.TaskCreatorprotected BioReplicationTask getReplicationThread()
public void stop()
ChannelReceiverstop in interface ChannelReceiverstop in class ReceiverBaseprotected void bind()
throws java.io.IOException
java.io.IOExceptionpublic void run()
run in interface java.lang.Runnablepublic void listen()
throws java.lang.Exception
java.lang.ExceptionCopyright © 2000-2013 Apache Software Foundation. All Rights Reserved.