Liferay 7.0-ce-b4

com.liferay.portal.kernel.messaging
Class BaseAsyncDestination

java.lang.Object
  extended by com.liferay.portal.kernel.messaging.BaseDestination
      extended by com.liferay.portal.kernel.messaging.BaseAsyncDestination
All Implemented Interfaces:
Destination
Direct Known Subclasses:
ParallelDestination, SerialDestination

public abstract class BaseAsyncDestination
extends BaseDestination


Field Summary
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
BaseAsyncDestination()
           
 
Method Summary
 void afterPropertiesSet()
           
 void close(boolean force)
           
protected  RejectedExecutionHandler createRejectionExecutionHandler()
           
 void destroy()
           
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, 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
 

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

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)

Liferay 7.0-ce-b4