org.apache.activemq.transport.nio
public final class SelectorManager extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
SelectorManager.Listener |
Modifier and Type | Field and Description |
---|---|
static SelectorManager |
SINGLETON |
Constructor and Description |
---|
SelectorManager() |
Modifier and Type | Method and Description |
---|---|
protected java.util.concurrent.ExecutorService |
createDefaultExecutor() |
java.util.concurrent.Executor |
getChannelExecutor() |
static SelectorManager |
getInstance() |
int |
getMaxChannelsPerWorker() |
java.util.concurrent.Executor |
getSelectorExecutor() |
void |
onWorkerEmptyEvent(SelectorWorker worker) |
void |
onWorkerNotFullEvent(SelectorWorker worker) |
SelectorSelection |
register(java.nio.channels.SocketChannel socketChannel,
SelectorManager.Listener listener) |
void |
setChannelExecutor(java.util.concurrent.Executor channelExecutor) |
void |
setMaxChannelsPerWorker(int maxChannelsPerWorker) |
void |
setSelectorExecutor(java.util.concurrent.Executor selectorExecutor) |
public static final SelectorManager SINGLETON
public SelectorManager()
protected java.util.concurrent.ExecutorService createDefaultExecutor()
public static SelectorManager getInstance()
public SelectorSelection register(java.nio.channels.SocketChannel socketChannel, SelectorManager.Listener listener) throws java.io.IOException
java.io.IOException
public void onWorkerEmptyEvent(SelectorWorker worker)
public void onWorkerNotFullEvent(SelectorWorker worker)
public java.util.concurrent.Executor getChannelExecutor()
public void setChannelExecutor(java.util.concurrent.Executor channelExecutor)
public int getMaxChannelsPerWorker()
public void setMaxChannelsPerWorker(int maxChannelsPerWorker)
public java.util.concurrent.Executor getSelectorExecutor()
public void setSelectorExecutor(java.util.concurrent.Executor selectorExecutor)
Copyright © 2005-2014. All Rights Reserved.