com.liferay.portal.kernel.nio.intraband.blocking

Class ExecutorIntraband

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

Author:

Shuyang Zhou

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ExecutorIntraband.ReadingCallable
protected class	ExecutorIntraband.WritingCallable

Nested classes/interfaces inherited from class com.liferay.portal.kernel.nio.intraband.BaseIntraband

BaseIntraband.SendSyncDatagramCompletionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executorService
protected static ThreadFactory	THREAD_FACTORY

Fields inherited from class com.liferay.portal.kernel.nio.intraband.BaseIntraband

datagramReceiveHandlersReference, defaultTimeout, open, REPLIED_ENUM_SET, responseWaitingMap, sequenceIdGenerator, timeoutMap

Constructor Summary

Constructors

Constructor and Description
ExecutorIntraband(long defaultTimeout)

Method Summary

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)

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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

THREAD_FACTORY

protected static final ThreadFactory THREAD_FACTORY

executorService

protected final ExecutorService executorService

Constructor Detail

ExecutorIntraband

public ExecutorIntraband(long defaultTimeout)

Method Detail

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