java.lang.Runnable
, ChannelReceiver
, Heartbeat
, ListenCallback
, RxTaskPool.TaskCreator
public class BioReceiver extends ReceiverBase implements java.lang.Runnable
Modifier and Type | Field | Description |
---|---|---|
protected java.net.ServerSocket |
serverSocket |
|
protected static StringManager |
sm |
MAX_UDP_SIZE
OPTION_DIRECT_BUFFER
Constructor | Description |
---|---|
BioReceiver() |
Modifier and Type | Method | 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
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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 java.net.ServerSocket serverSocket
public void start() throws java.io.IOException
ChannelReceiver
start
in interface ChannelReceiver
start
in class ReceiverBase
java.io.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 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-2019 Apache Software Foundation. All Rights Reserved.