public class BioReceiver extends ReceiverBase implements java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
protected java.net.ServerSocket |
serverSocket |
OPTION_DIRECT_BUFFERMAX_UDP_SIZE| 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, bindUdp, doListen, getAddress, getAutoBind, getBind, getDirect, getExecutor, getHost, getListener, getMaxIdleTime, getMaxTasks, getMaxThreads, getMessageListener, getMinTasks, getMinThreads, getOoBInline, getPort, getRxBufSize, getSecurePort, getSelectorTimeout, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTaskPool, getTcpListenAddress, getTcpListenPort, getTcpNoDelay, getTcpSelectorTimeout, getTcpThreadCount, getTimeout, getTxBufSize, getUdpPort, getUdpRxBufSize, getUdpTxBufSize, getUseBufferPool, getWorkerThreadOptions, heartbeat, isDaemon, isListening, messageDataReceived, setAddress, setAutoBind, setBind, setDaemon, setDirect, setExecutor, setHost, setListen, setListener, setMaxIdleTime, setMaxTasks, setMaxThreads, setMessageListener, setMinTasks, setMinThreads, setOoBInline, setPool, setPort, setRxBufSize, setSecurePort, setSelectorTimeout, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpListenAddress, setTcpListenPort, setTcpNoDelay, setTcpSelectorTimeout, setTcpThreadCount, setTimeout, setTxBufSize, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, setUseBufferPoolpublic 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-2015 Apache Software Foundation. All Rights Reserved.