public class NioReceiver extends ReceiverBase implements Runnable
Modifier and Type | Field and Description |
---|---|
protected LinkedList<Runnable> |
events |
protected long |
lastCheck |
protected static StringManager |
sm
The string manager for this package.
|
OPTION_DIRECT_BUFFER
MAX_UDP_SIZE
Constructor and Description |
---|
NioReceiver() |
Modifier and Type | Method and Description |
---|---|
void |
addEvent(Runnable event) |
protected void |
bind() |
static void |
cancelledKey(SelectionKey key) |
AbstractRxTask |
createRxTask() |
void |
events() |
protected void |
listen()
get data from channel and store in byte array
send it to cluster
|
protected void |
readDataFromSocket(SelectionKey key)
Sample data handler method for a channel with data ready to read.
|
protected void |
registerChannel(Selector selector,
SelectableChannel channel,
int ops,
Object attach)
Register the given channel with the given selector for
the given operations of interest
|
void |
run()
Start thread and listen
|
protected void |
socketTimeouts() |
void |
start()
start cluster receiver
|
void |
stop()
Stop listening for messages
|
protected void |
stopListening()
Close Selector.
|
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, setUseBufferPool
protected static final StringManager sm
protected final LinkedList<Runnable> events
protected long lastCheck
public void stop()
ChannelReceiver
stop
in interface ChannelReceiver
stop
in class ReceiverBase
public void start() throws IOException
start
in interface ChannelReceiver
start
in class ReceiverBase
IOException
ChannelReceiver.start()
public AbstractRxTask createRxTask()
createRxTask
in interface RxTaskPool.TaskCreator
protected void bind() throws IOException
IOException
public void addEvent(Runnable event)
public void events()
public static void cancelledKey(SelectionKey key)
protected void socketTimeouts()
protected void listen() throws Exception
protected void stopListening()
ReceiverBase.stop()
protected void registerChannel(Selector selector, SelectableChannel channel, int ops, Object attach) throws Exception
Exception
protected void readDataFromSocket(SelectionKey key) throws Exception
key
- A SelectionKey object associated with a channel
determined by the selector to be ready for reading. If the
channel returns an EOF condition, it is closed here, which
automatically invalidates the associated key. The selector
will then de-register the channel on the next select call.Exception
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.