com.liferay.portal.kernel.nio.intraband.nonblocking
Class SelectorIntraBand
java.lang.Object
com.liferay.portal.kernel.nio.intraband.BaseIntraBand
com.liferay.portal.kernel.nio.intraband.nonblocking.SelectorIntraBand
- All Implemented Interfaces:
- IntraBand
public class SelectorIntraBand
- extends BaseIntraBand
| Methods inherited from class com.liferay.portal.kernel.nio.intraband.BaseIntraBand |
addResponseWaitingDatagram, cleanUpTimeoutResponseWaitingDatagrams, doSendSyncDatagram, ensureOpen, generateSequenceId, getDatagramReceiveHandlers, handleReading, handleWriting, isOpen, registerDatagramReceiveHandler, removeResponseWaitingDatagram, sendDatagram, sendDatagram, sendDatagram, sendSyncDatagram, sendSyncDatagram, unregisterDatagramReceiveHandler |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
threadFactory
protected static final ThreadFactory threadFactory
pollingThread
protected final Thread pollingThread
registerQueue
protected final Queue<FutureTask<RegistrationReference>> registerQueue
selector
protected final Selector selector
SelectorIntraBand
public SelectorIntraBand(long defaultTimeout)
throws IOException
- Throws:
IOException
close
public void close()
throws InterruptedException,
IOException
- Specified by:
close in interface IntraBand- Overrides:
close in class BaseIntraBand
- Throws:
InterruptedException
IOException
registerChannel
public RegistrationReference registerChannel(Channel channel)
throws IOException
- Throws:
IOException
registerChannel
public RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel)
throws IOException
- Throws:
IOException
doSendDatagram
protected void doSendDatagram(RegistrationReference registrationReference,
Datagram datagram)
- Specified by:
doSendDatagram in class BaseIntraBand
registerChannels
protected void registerChannels()