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
| 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 |
portalExecutorManager
protected volatile PortalExecutorManager portalExecutorManager
serviceTracker
protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager> serviceTracker
BaseAsyncDestination
public BaseAsyncDestination()
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)