com.liferay.portal.kernel.nio.intraband.nonblocking
Class SelectorIntraband

java.lang.Object
  com.liferay.portal.kernel.nio.intraband.BaseIntraband
      com.liferay.portal.kernel.nio.intraband.nonblocking.SelectorIntraband

All Implemented Interfaces:

Intraband

public class SelectorIntraband
extends BaseIntraband

Nested Class Summary

protected class

SelectorIntraband.RegisterCallable

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

BaseIntraband.SendSyncDatagramCompletionHandler

Field Summary

protected Thread	pollingThread
protected Queue<FutureTask<RegistrationReference>>	registerQueue
protected Selector	selector
protected static ThreadFactory	threadFactory

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

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

Constructor Summary

SelectorIntraband(long defaultTimeout)

Method Summary

void	close()
protected void	doSendDatagram(RegistrationReference registrationReference, Datagram datagram)
RegistrationReference	registerChannel(Channel channel)
RegistrationReference	registerChannel(ScatteringByteChannel scatteringByteChannel, GatheringByteChannel gatheringByteChannel)
protected void	registerChannels()

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

threadFactory

protected static final ThreadFactory threadFactory

pollingThread

protected final Thread pollingThread

registerQueue

protected final Queue<FutureTask<RegistrationReference>> registerQueue

selector

protected final Selector selector

Constructor Detail

SelectorIntraband

public SelectorIntraband(long defaultTimeout)
                  throws IOException

Throws:

IOException

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)
                                      throws IOException

Throws:

IOException

registerChannel

public RegistrationReference registerChannel(ScatteringByteChannel scatteringByteChannel,
                                             GatheringByteChannel gatheringByteChannel)
                                      throws IOException

Throws:

IOException

doSendDatagram

protected void doSendDatagram(RegistrationReference registrationReference,
                              Datagram datagram)

Specified by:

doSendDatagram in class BaseIntraband

registerChannels

protected void registerChannels()