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