com.liferay.portal.kernel.messaging
Class ParallelDestination

java.lang.Object
  com.liferay.portal.kernel.messaging.BaseDestination
      com.liferay.portal.kernel.messaging.ArrayDispatcherDestination
          com.liferay.portal.kernel.messaging.ParallelDestination

All Implemented Interfaces:

Destination

Direct Known Subclasses:

SerialDestination

public class ParallelDestination
extends ArrayDispatcherDestination

View Source

Destination that delivers a message to a list of message listeners in parallel.

Author:

Michael C. Han

Constructor Summary

ParallelDestination(java.lang.String name)

ParallelDestination(java.lang.String name, int workersCoreSize, int workersMaxSize)

Method Summary

protected void	dispatch(MessageListener[] listeners, java.lang.Object message)
protected void	dispatch(MessageListener[] listeners, java.lang.String message)

Methods inherited from class com.liferay.portal.kernel.messaging.ArrayDispatcherDestination

register, send, send, unregister

Methods inherited from class com.liferay.portal.kernel.messaging.BaseDestination

close, close, doClose, doOpen, getName, getThreadPoolExecutor, getWorkersCoreSize, getWorkersMaxSize, open

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParallelDestination

public ParallelDestination(java.lang.String name)

ParallelDestination

public ParallelDestination(java.lang.String name,
                           int workersCoreSize,
                           int workersMaxSize)

Method Detail

dispatch

protected void dispatch(MessageListener[] listeners,
                        java.lang.Object message)

Specified by:

dispatch in class ArrayDispatcherDestination

dispatch

protected void dispatch(MessageListener[] listeners,
                        java.lang.String message)

Specified by:

dispatch in class ArrayDispatcherDestination