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

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 java.util.concurrent.ExecutorService	executorService
protected static java.util.concurrent.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(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)

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

Field Detail

THREAD_FACTORY

protected static final java.util.concurrent.ThreadFactory THREAD_FACTORY

executorService

protected final java.util.concurrent.ExecutorService executorService

Constructor Detail

ExecutorIntraband

public ExecutorIntraband(long defaultTimeout)

Method Detail

close

public void close()
           throws java.lang.InterruptedException,
                  java.io.IOException

Specified by:

close in interface Intraband

Overrides:

close in class BaseIntraband

Throws:

java.lang.InterruptedException

java.io.IOException

registerChannel

public RegistrationReference registerChannel(java.nio.channels.Channel channel)

registerChannel

public RegistrationReference registerChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel,
                                             java.nio.channels.GatheringByteChannel gatheringByteChannel)

doRegisterChannel

protected RegistrationReference doRegisterChannel(java.nio.channels.ScatteringByteChannel scatteringByteChannel,
                                                  java.nio.channels.GatheringByteChannel gatheringByteChannel)

doSendDatagram

protected void doSendDatagram(RegistrationReference registrationReference,
                              Datagram datagram)

Specified by:

doSendDatagram in class BaseIntraband