com.liferay.portal.kernel.messaging
Class BaseAsyncDestination

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

All Implemented Interfaces:

Destination

Direct Known Subclasses:

ParallelDestination, SerialDestination

public abstract class BaseAsyncDestination
extends BaseDestination

Field Summary

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

messageListeners, name

Constructor Summary

BaseAsyncDestination()

BaseAsyncDestination(String name)
Deprecated.

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

Method Summary

void	close(boolean force)
protected RejectedExecutionHandler	createRejectionExecutionHandler()
protected abstract void	dispatch(Set<MessageListener> messageListeners, Message message)
DestinationStatistics	getDestinationStatistics()
int	getMaximumQueueSize()
protected ThreadPoolExecutor	getThreadPoolExecutor()
int	getWorkersCoreSize()
int	getWorkersMaxSize()
void	open()
protected void	populateMessageFromThreadLocals(Message message)
protected void	populateThreadLocalsFromMessage(Message message)
void	send(Message message)
void	setMaximumQueueSize(int maximumQueueSize)
void	setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
void	setWorkersCoreSize(int workersCoreSize)
void	setWorkersMaxSize(int workersMaxSize)

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

addDestinationEventListener, afterPropertiesSet, close, copyDestinationEventListeners, copyMessageListeners, fireMessageListenerRegisteredEvent, fireMessageListenerUnregisteredEvent, getMessageListenerCount, getMessageListeners, getName, isRegistered, register, register, registerMessageListener, removeDestinationEventListener, removeDestinationEventListeners, setName, unregister, unregister, unregisterMessageListener, unregisterMessageListeners

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseAsyncDestination

public BaseAsyncDestination()

BaseAsyncDestination

public BaseAsyncDestination(String name)

Deprecated.

BaseAsyncDestination

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

Deprecated.

Method Detail

close

public void close(boolean force)

Specified by:

close in interface Destination

Overrides:

close in class BaseDestination

getDestinationStatistics

public DestinationStatistics getDestinationStatistics()

getMaximumQueueSize

public int getMaximumQueueSize()

getWorkersCoreSize

public int getWorkersCoreSize()

getWorkersMaxSize

public int getWorkersMaxSize()

open

public void open()

Specified by:

open in interface Destination

Overrides:

open in class BaseDestination

send

public void send(Message message)

setMaximumQueueSize

public void setMaximumQueueSize(int maximumQueueSize)

setRejectedExecutionHandler

public void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)

setWorkersCoreSize

public void setWorkersCoreSize(int workersCoreSize)

setWorkersMaxSize

public void setWorkersMaxSize(int workersMaxSize)

createRejectionExecutionHandler

protected RejectedExecutionHandler createRejectionExecutionHandler()

dispatch

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

getThreadPoolExecutor

protected ThreadPoolExecutor getThreadPoolExecutor()

populateMessageFromThreadLocals

protected void populateMessageFromThreadLocals(Message message)

populateThreadLocalsFromMessage

protected void populateThreadLocalsFromMessage(Message message)