public class ParallelDestination extends BaseAsyncDestination
Destination that delivers a message to a list of message listeners in parallel.
portalExecutorManager, serviceTrackermessageListeners, name| Constructor and Description |
|---|
ParallelDestination() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
dispatch(Set<MessageListener> messageListeners,
Message message) |
afterPropertiesSet, close, createRejectionExecutionHandler, destroy, getDestinationStatistics, getMaximumQueueSize, getThreadPoolExecutor, getWorkersCoreSize, getWorkersMaxSize, open, populateMessageFromThreadLocals, populateThreadLocalsFromMessage, send, setMaximumQueueSize, setRejectedExecutionHandler, setWorkersCoreSize, setWorkersMaxSizeaddDestinationEventListener, close, copyDestinationEventListeners, copyMessageListeners, fireMessageListenerRegisteredEvent, fireMessageListenerUnregisteredEvent, getMessageListenerCount, getMessageListeners, getName, isRegistered, register, register, registerMessageListener, removeDestinationEventListener, removeDestinationEventListeners, setName, unregister, unregister, unregisterMessageListener, unregisterMessageListenersprotected void dispatch(Set<MessageListener> messageListeners, Message message)
dispatch in class BaseAsyncDestination