public class BioReceiver extends ReceiverBase implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
protected java.net.ServerSocket |
serverSocket |
protected static StringManager |
sm |
OPTION_DIRECT_BUFFER
MAX_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, getChannel, 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, 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
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-2018 Apache Software Foundation. All Rights Reserved.