com.liferay.portal.kernel.messaging
Class ArrayDispatcherDestination

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

Constructor Summary
ArrayDispatcherDestination(java.lang.String name)
           
ArrayDispatcherDestination(java.lang.String name, int workersCoreSize, int workersMaxSize)
           
 
Method Summary
protected abstract  void dispatch(java.util.Set<MessageListener> listeners, 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

ArrayDispatcherDestination

public ArrayDispatcherDestination(java.lang.String name)

ArrayDispatcherDestination

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

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)