com.liferay.portal.kernel.messaging
Class ArrayDispatcherDestination
java.lang.Object
com.liferay.portal.kernel.messaging.BaseDestination
com.liferay.portal.kernel.messaging.ArrayDispatcherDestination
- All Implemented Interfaces:
- Destination
- Direct Known Subclasses:
- DummyArrayDispatcherDestination, ParallelDestination, SerialDestination
public abstract class ArrayDispatcherDestination
- extends BaseDestination
View Source
- Author:
- Michael C. Han, Brian Wing Shun Chan
Methods inherited from class com.liferay.portal.kernel.messaging.BaseDestination |
close, close, doClose, doOpen, getName, getStatistics, getThreadPoolExecutor, getWorkersCoreSize, getWorkersMaxSize, isRegistered, open |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ArrayDispatcherDestination
public ArrayDispatcherDestination(java.lang.String name)
ArrayDispatcherDestination
public ArrayDispatcherDestination(java.lang.String name,
int workersCoreSize,
int workersMaxSize)
getListenerCount
public int getListenerCount()
- Specified by:
getListenerCount
in interface Destination
- Specified by:
getListenerCount
in class BaseDestination
register
public void register(MessageListener listener)
send
public void send(Message message)
unregister
public boolean unregister(MessageListener listener)
dispatch
protected abstract void dispatch(java.util.Set<MessageListener> listeners,
Message message)