com.liferay.portal.kernel.messaging
Class IteratorDispatcherDestination

java.lang.Object
  extended by com.liferay.portal.kernel.messaging.BaseDestination
      extended by 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

Constructor Summary
IteratorDispatcherDestination(java.lang.String name)
           
IteratorDispatcherDestination(java.lang.String name, int workersCoreSize, int workersMaxSize)
           
 
Method Summary
protected abstract  void dispatch(java.util.Iterator<MessageListener> listenersItr, Message message)
           
 int getListenerCount()
           
 void register(MessageListener listener)
           
 void send(Message message)
           
 boolean unregister(MessageListener listener)
           
 
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
 

Constructor Detail

IteratorDispatcherDestination

public IteratorDispatcherDestination(java.lang.String name)

IteratorDispatcherDestination

public IteratorDispatcherDestination(java.lang.String name,
                                     int workersCoreSize,
                                     int workersMaxSize)
Method Detail

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)