@Deprecated public class BioReceiver extends ReceiverBase implements Runnable
Modifier and Type | Field and Description |
---|---|
protected ServerSocket |
serverSocket
Deprecated.
|
protected static StringManager |
sm
Deprecated.
|
OPTION_DIRECT_BUFFER
MAX_UDP_SIZE
Constructor and Description |
---|
BioReceiver()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
bind()
Deprecated.
|
AbstractRxTask |
createRxTask()
Deprecated.
|
protected BioReplicationTask |
getReplicationThread()
Deprecated.
|
void |
listen()
Deprecated.
|
void |
run()
Deprecated.
|
void |
start()
Deprecated.
Start listening for incoming messages on the host/port
|
void |
stop()
Deprecated.
Stop listening for messages
|
bind, bindUdp, doListen, getActiveCount, getAddress, getAutoBind, getBind, getChannel, getCompletedTaskCount, getDirect, getExecutor, getHost, getListener, getMaxIdleTime, getMaxTasks, getMaxThreads, getMessageListener, getMinTasks, getMinThreads, getOoBInline, getPoolSize, getPort, getRxBufSize, getSecurePort, getSelectorTimeout, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTaskCount, getTaskPool, getTcpNoDelay, getTimeout, getTxBufSize, getUdpPort, getUdpRxBufSize, getUdpTxBufSize, getUseBufferPool, getWorkerThreadOptions, heartbeat, isDaemon, isListening, messageDataReceived, setAddress, setAutoBind, setBind, setChannel, 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, setUseBufferPool
protected static final StringManager sm
protected ServerSocket serverSocket
public void start() throws IOException
ChannelReceiver
start
in interface ChannelReceiver
start
in class ReceiverBase
IOException
- Listen failedpublic 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 IOException
IOException
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.