com.liferay.portal.kernel.messaging

Class BaseAsyncDestination

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

Author:

Michael C. Han, Shuyang Zhou

Field Summary

Fields

Modifier and Type	Field and Description
protected PortalExecutorManager	portalExecutorManager
protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager>	serviceTracker

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

messageListeners, name

Constructor Summary

Constructors

Constructor and Description
BaseAsyncDestination()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	close(boolean force)
protected RejectedExecutionHandler	createRejectionExecutionHandler() Deprecated. As of Judson (7.1.x), with no direct replacement
void	destroy()
protected abstract void	dispatch(Set<MessageListener> messageListeners, Message message)
DestinationStatistics	getDestinationStatistics()
int	getMaximumQueueSize()
protected ThreadPoolExecutor	getThreadPoolExecutor() Deprecated. As of Judson (7.1.x), with no direct replacement
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) Deprecated. As of Judson (7.1.x), with no direct replacement
void	setWorkersCoreSize(int workersCoreSize)
void	setWorkersMaxSize(int workersMaxSize)

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

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

Methods inherited from class Object

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

Field Detail

portalExecutorManager

protected volatile PortalExecutorManager portalExecutorManager

serviceTracker

protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager> serviceTracker

Constructor Detail

BaseAsyncDestination

public BaseAsyncDestination()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Overrides:

afterPropertiesSet in class BaseDestination

close

public void close(boolean force)

Specified by:

close in interface Destination

Overrides:

close in class BaseDestination

destroy

public void destroy()

Specified by:

destroy in interface Destination

Overrides:

destroy in class BaseDestination

getDestinationStatistics

public DestinationStatistics getDestinationStatistics()

Specified by:

getDestinationStatistics in interface Destination

Overrides:

getDestinationStatistics in class BaseDestination

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)

Specified by:

send in interface Destination

Overrides:

send in class BaseDestination

setMaximumQueueSize

public void setMaximumQueueSize(int maximumQueueSize)

setRejectedExecutionHandler

@Deprecated
public void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)

Deprecated. As of Judson (7.1.x), with no direct replacement

setWorkersCoreSize

public void setWorkersCoreSize(int workersCoreSize)

setWorkersMaxSize

public void setWorkersMaxSize(int workersMaxSize)

createRejectionExecutionHandler

@Deprecated
protected RejectedExecutionHandler createRejectionExecutionHandler()

Deprecated. As of Judson (7.1.x), with no direct replacement

dispatch

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

getThreadPoolExecutor

@Deprecated
protected ThreadPoolExecutor getThreadPoolExecutor()

Deprecated. As of Judson (7.1.x), with no direct replacement

populateMessageFromThreadLocals

protected void populateMessageFromThreadLocals(Message message)

populateThreadLocalsFromMessage

protected void populateThreadLocalsFromMessage(Message message)