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 java.util.concurrent.ExecutorService |
executorService |
protected static java.util.concurrent.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(java.nio.channels.ScatteringByteChannel scatteringByteChannel,
java.nio.channels.GatheringByteChannel gatheringByteChannel) |
protected void |
doSendDatagram(RegistrationReference registrationReference,
Datagram datagram) |
RegistrationReference |
registerChannel(java.nio.channels.Channel channel) |
RegistrationReference |
registerChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel,
java.nio.channels.GatheringByteChannel gatheringByteChannel) |
addResponseWaitingDatagram, cleanUpTimeoutResponseWaitingDatagrams, doSendSyncDatagram, ensureOpen, generateSequenceId, getDatagramReceiveHandlers, handleReading, handleWriting, isOpen, registerDatagramReceiveHandler, removeResponseWaitingDatagram, sendDatagram, sendDatagram, sendDatagram, sendSyncDatagram, sendSyncDatagram, unregisterDatagramReceiveHandlerprotected static final java.util.concurrent.ThreadFactory THREAD_FACTORY
protected final java.util.concurrent.ExecutorService executorService
public void close()
throws java.lang.InterruptedException,
java.io.IOException
close in interface Intrabandclose in class BaseIntrabandjava.lang.InterruptedExceptionjava.io.IOExceptionpublic RegistrationReference registerChannel(java.nio.channels.Channel channel)
public RegistrationReference registerChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel, java.nio.channels.GatheringByteChannel gatheringByteChannel)
protected RegistrationReference doRegisterChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel, java.nio.channels.GatheringByteChannel gatheringByteChannel)
protected void doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
doSendDatagram in class BaseIntraband