org.apache.activemq.transport.nio
Class SelectorManager
java.lang.Object
org.apache.activemq.transport.nio.SelectorManager
public final class SelectorManager
- extends Object
The SelectorManager will manage one Selector and the thread that checks the
selector.
We may need to consider running more than one thread to check the selector if
servicing the selector takes too long.
- Version:
- $Rev: 46019 $ $Date: 2004-09-14 05:56:06 -0400 (Tue, 14 Sep 2004) $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SINGLETON
public static final SelectorManager SINGLETON
SelectorManager
public SelectorManager()
createDefaultExecutor
protected ExecutorService createDefaultExecutor()
getInstance
public static SelectorManager getInstance()
register
public SelectorSelection register(SocketChannel socketChannel,
SelectorManager.Listener listener)
throws IOException
- Throws:
IOException
onWorkerEmptyEvent
public void onWorkerEmptyEvent(SelectorWorker worker)
onWorkerNotFullEvent
public void onWorkerNotFullEvent(SelectorWorker worker)
getChannelExecutor
public Executor getChannelExecutor()
setChannelExecutor
public void setChannelExecutor(Executor channelExecutor)
getMaxChannelsPerWorker
public int getMaxChannelsPerWorker()
setMaxChannelsPerWorker
public void setMaxChannelsPerWorker(int maxChannelsPerWorker)
getSelectorExecutor
public Executor getSelectorExecutor()
setSelectorExecutor
public void setSelectorExecutor(Executor selectorExecutor)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.