com.liferay.portal.kernel.messaging
Class IteratorDispatcherDestination
java.lang.Object
com.liferay.portal.kernel.messaging.BaseDestination
com.liferay.portal.kernel.messaging.IteratorDispatcherDestination
- All Implemented Interfaces:
- Destination
- Direct Known Subclasses:
- DummyIteratorDispatcherDestination, TempDestination
public abstract class IteratorDispatcherDestination
- 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 |
IteratorDispatcherDestination
public IteratorDispatcherDestination(java.lang.String name)
IteratorDispatcherDestination
public IteratorDispatcherDestination(java.lang.String name,
int workersCoreSize,
int workersMaxSize)
register
public void register(MessageListener listener)
send
public void send(Message message)
unregister
public boolean unregister(MessageListener listener)
getListenerCount
public int getListenerCount()
- Specified by:
getListenerCount
in interface Destination
- Specified by:
getListenerCount
in class BaseDestination
dispatch
protected abstract void dispatch(java.util.Iterator<MessageListener> listenersItr,
Message message)