public abstract class NIOTransport extends AbstractTransport
Transport.State
Modifier and Type | Field and Description |
---|---|
protected NIOChannelDistributor |
nioChannelDistributor |
protected static Random |
RANDOM |
protected SelectionKeyHandler |
selectionKeyHandler |
protected SelectorHandler |
selectorHandler |
protected SelectorProvider |
selectorProvider |
protected SelectorRunner[] |
selectorRunners |
attributeBuilder, connectionMonitoringConfig, isBlocking, isStandalone, kernelPool, kernelPoolConfig, managedWorkerPool, memoryManager, name, processor, processorSelector, readBufferSize, readTimeout, state, strategy, threadPoolMonitoringConfig, transportMonitoringConfig, workerPoolConfig, workerThreadPool, writeBufferSize, writeTimeout
DEFAULT_READ_BUFFER_SIZE, DEFAULT_READ_TIMEOUT, DEFAULT_WRITE_TIMEOUT
Constructor and Description |
---|
NIOTransport(String name) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
closeConnection(Connection connection)
Close the connection, managed by Transport
|
protected int |
getDefaultSelectorRunnersCount() |
NIOChannelDistributor |
getNIOChannelDistributor() |
SelectionKeyHandler |
getSelectionKeyHandler() |
SelectorHandler |
getSelectorHandler() |
SelectorProvider |
getSelectorProvider()
Get the
SelectorProvider to be used by this transport. |
protected SelectorRunner[] |
getSelectorRunners() |
int |
getSelectorRunnersCount() |
protected static void |
notifyProbesError(NIOTransport transport,
Throwable error)
Notify registered
TransportProbe s about the error. |
protected static void |
notifyProbesPause(NIOTransport transport)
Notify registered
TransportProbe s about the pause event. |
protected static void |
notifyProbesResume(NIOTransport transport)
Notify registered
TransportProbe s about the resume event. |
protected static void |
notifyProbesStart(NIOTransport transport)
Notify registered
TransportProbe s about the start event. |
protected static void |
notifyProbesStop(NIOTransport transport)
Notify registered
TransportProbe s about the stop event. |
void |
notifyTransportError(Throwable error)
Method gets invoked, when error occur during the Transport lifecycle.
|
void |
setNIOChannelDistributor(NIOChannelDistributor nioChannelDistributor) |
void |
setSelectionKeyHandler(SelectionKeyHandler selectionKeyHandler) |
void |
setSelectorHandler(SelectorHandler selectorHandler) |
void |
setSelectorProvider(SelectorProvider selectorProvider)
Set the
SelectorProvider to be used by this transport. |
void |
setSelectorRunnersCount(int selectorRunnersCount) |
void |
start()
Starts the transport
|
protected void |
startSelectorRunners() |
protected void |
stopSelectorRunners() |
configureBlocking, createJmxManagementObject, getAttributeBuilder, getConnectionMonitoringConfig, getIOStrategy, getKernelThreadPool, getKernelThreadPoolConfig, getMemoryManager, getMonitoringConfig, getName, getProcessor, getProcessorSelector, getReadBufferSize, getReadTimeout, getState, getThreadPoolMonitoringConfig, getWorkerThreadPool, getWorkerThreadPoolConfig, getWriteBufferSize, getWriteTimeout, isBlocking, isPaused, isStandalone, isStopped, notifyProbesBeforePause, notifyProbesBeforeResume, notifyProbesBeforeStart, notifyProbesBeforeStop, notifyProbesConfigChanged, notifyProbesPause, notifyProbesStop, obtainProcessor, pause, resume, setAttributeBuilder, setIOStrategy, setKernelPool0, setKernelThreadPool, setKernelThreadPoolConfig, setMemoryManager, setName, setProcessor, setProcessorSelector, setReadBufferSize, setReadTimeout, setWorkerThreadPool, setWorkerThreadPool0, setWorkerThreadPoolConfig, setWriteBufferSize, setWriteTimeout, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configureStandalone, fireIOEvent, getReader, getReader, getWriter, getWriter
protected static final Random RANDOM
protected SelectorHandler selectorHandler
protected SelectionKeyHandler selectionKeyHandler
protected SelectorRunner[] selectorRunners
protected NIOChannelDistributor nioChannelDistributor
protected SelectorProvider selectorProvider
public NIOTransport(String name)
public SelectionKeyHandler getSelectionKeyHandler()
public void setSelectionKeyHandler(SelectionKeyHandler selectionKeyHandler)
public SelectorHandler getSelectorHandler()
public void setSelectorHandler(SelectorHandler selectorHandler)
public int getSelectorRunnersCount()
public void setSelectorRunnersCount(int selectorRunnersCount)
public SelectorProvider getSelectorProvider()
SelectorProvider
to be used by this transport.SelectorProvider
to be used by this transport.public void setSelectorProvider(SelectorProvider selectorProvider)
SelectorProvider
to be used by this transport.selectorProvider
- the SelectorProvider
.public void start() throws IOException
AbstractTransport
start
in interface Transport
start
in class AbstractTransport
IOException
protected void startSelectorRunners() throws IOException
IOException
protected void stopSelectorRunners() throws IOException
IOException
public NIOChannelDistributor getNIOChannelDistributor()
public void setNIOChannelDistributor(NIOChannelDistributor nioChannelDistributor)
public void notifyTransportError(Throwable error)
error
- Throwable
.protected SelectorRunner[] getSelectorRunners()
protected static void notifyProbesError(NIOTransport transport, Throwable error)
TransportProbe
s about the error.transport
- the Transport event occurred on.protected static void notifyProbesStart(NIOTransport transport)
TransportProbe
s about the start event.transport
- the Transport event occurred on.protected static void notifyProbesStop(NIOTransport transport)
TransportProbe
s about the stop event.transport
- the Transport event occurred on.protected static void notifyProbesPause(NIOTransport transport)
TransportProbe
s about the pause event.transport
- the Transport event occurred on.protected static void notifyProbesResume(NIOTransport transport)
TransportProbe
s about the resume event.transport
- the Transport event occurred on.protected abstract void closeConnection(Connection connection) throws IOException
AbstractTransport
closeConnection
in class AbstractTransport
IOException
protected int getDefaultSelectorRunnersCount()
Copyright © 2013 Oracle Corporation. All Rights Reserved.