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, setUseBufferPool
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getHost, getMessageListener, getPort, getSecurePort, setMessageListener
messageDataReceived
protected static Log log
protected java.net.ServerSocket serverSocket
public void start() throws java.io.IOException
ChannelReceiver
start
in interface ChannelReceiver
start
in class ReceiverBase
java.io.IOException
public AbstractRxTask createRxTask()
createRxTask
in interface RxTaskPool.TaskCreator
protected BioReplicationTask getReplicationThread()
public void stop()
ChannelReceiver
stop
in interface ChannelReceiver
stop
in class ReceiverBase
protected void bind() throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
public void listen() throws java.lang.Exception
java.lang.Exception
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.