com.liferay.portal.kernel.messaging
Class ParallelDestination

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

All Implemented Interfaces:

Destination

public class ParallelDestination
extends BaseDestination

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

Constructor Summary

ParallelDestination()

ParallelDestination(String name)
Deprecated.

ParallelDestination(String name, int workersCoreSize, int workersMaxSize)
Deprecated.

Method Summary

protected void

dispatch(Set<MessageListener> messageListeners, Message message)

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

addDestinationEventListener, afterPropertiesSet, close, close, copyDestinationEventListeners, copyMessageListeners, doClose, doOpen, fireMessageListenerRegisteredEvent, fireMessageListenerUnregisteredEvent, getDestinationStatistics, getMaximumQueueSize, getMessageListenerCount, getName, getThreadPoolExecutor, getWorkersCoreSize, getWorkersMaxSize, isRegistered, open, register, register, registerMessageListener, removeDestinationEventListener, removeDestinationEventListeners, send, setMaximumQueueSize, setName, setWorkersCoreSize, setWorkersMaxSize, unregister, unregister, unregisterMessageListener, unregisterMessageListeners

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelDestination

public ParallelDestination()

ParallelDestination

public ParallelDestination(String name)

Deprecated.

ParallelDestination

public ParallelDestination(String name,
                           int workersCoreSize,
                           int workersMaxSize)

Deprecated.

Method Detail

dispatch

protected void dispatch(Set<MessageListener> messageListeners,
                        Message message)

Specified by:

dispatch in class BaseDestination