com.liferay.portal.kernel.nio.intraband.blocking
Class ExecutorIntraBand
java.lang.Object
com.liferay.portal.kernel.nio.intraband.BaseIntraBand
com.liferay.portal.kernel.nio.intraband.blocking.ExecutorIntraBand
- All Implemented Interfaces:
- IntraBand
public class ExecutorIntraBand
- 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 |
THREAD_FACTORY
protected static final ThreadFactory THREAD_FACTORY
executorService
protected final ExecutorService executorService
ExecutorIntraBand
public ExecutorIntraBand(long defaultTimeout)
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)
registerChannel
public RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel)
doRegisterChannel
protected RegistrationReference doRegisterChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel)
doSendDatagram
protected void doSendDatagram(RegistrationReference registrationReference,
Datagram datagram)
- Specified by:
doSendDatagram in class BaseIntraBand