public class ExecutorIntraband extends BaseIntraband
| Modifier and Type | Class and Description |
|---|---|
protected class |
ExecutorIntraband.ReadingCallable |
protected class |
ExecutorIntraband.WritingCallable |
BaseIntraband.SendSyncDatagramCompletionHandler| Modifier and Type | Field and Description |
|---|---|
protected ExecutorService |
executorService |
protected static ThreadFactory |
THREAD_FACTORY |
datagramReceiveHandlersReference, defaultTimeout, open, REPLIED_ENUM_SET, responseWaitingMap, sequenceIdGenerator, timeoutMap| Constructor and Description |
|---|
ExecutorIntraband(long defaultTimeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
protected RegistrationReference |
doRegisterChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel) |
protected void |
doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
RegistrationReference |
registerChannel(Channel channel) |
RegistrationReference |
registerChannel(ScatteringByteChannel scatteringByteChannel,
GatheringByteChannel gatheringByteChannel) |
addResponseWaitingDatagram, cleanUpTimeoutResponseWaitingDatagrams, doSendSyncDatagram, ensureOpen, generateSequenceId, getDatagramReceiveHandlers, handleReading, handleWriting, isOpen, registerDatagramReceiveHandler, removeResponseWaitingDatagram, sendDatagram, sendDatagram, sendDatagram, sendSyncDatagram, sendSyncDatagram, unregisterDatagramReceiveHandlerprotected static final ThreadFactory THREAD_FACTORY
protected final ExecutorService executorService
public void close()
throws InterruptedException,
IOException
close in interface Intrabandclose in class BaseIntrabandInterruptedExceptionIOExceptionpublic RegistrationReference registerChannel(Channel channel)
public RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel, GatheringByteChannel gatheringByteChannel)
protected RegistrationReference doRegisterChannel(ScatteringByteChannel scatteringByteChannel, GatheringByteChannel gatheringByteChannel)
protected void doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
doSendDatagram in class BaseIntraband