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, unregisterDatagramReceiveHandler
protected static final ThreadFactory THREAD_FACTORY
protected final ExecutorService executorService
public void close() throws InterruptedException, IOException
close
in interface Intraband
close
in class BaseIntraband
InterruptedException
IOException
public 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