public class BioReceiver extends ReceiverBase implements Runnable
| Modifier and Type | Field and Description |
|---|---|
protected 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, getTcpNoDelay, 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, setTcpNoDelay, setTimeout, setTxBufSize, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, setUseBufferPoolprotected ServerSocket serverSocket
public void start()
throws IOException
ChannelReceiverstart in interface ChannelReceiverstart in class ReceiverBaseIOExceptionpublic AbstractRxTask createRxTask()
createRxTask in interface RxTaskPool.TaskCreatorprotected BioReplicationTask getReplicationThread()
public void stop()
ChannelReceiverstop in interface ChannelReceiverstop in class ReceiverBaseprotected void bind()
throws IOException
IOExceptionCopyright © 2000-2014 Apache Software Foundation. All Rights Reserved.