public abstract class BaseAsyncDestination extends BaseDestination
| Modifier and Type | Field and Description |
|---|---|
protected PortalExecutorManager |
portalExecutorManager |
protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager> |
serviceTracker |
messageListeners, name| Constructor and Description |
|---|
BaseAsyncDestination() |
| Modifier and Type | Method and Description |
|---|---|
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) |
addDestinationEventListener, close, copyDestinationEventListeners, copyMessageListeners, fireMessageListenerRegisteredEvent, fireMessageListenerUnregisteredEvent, getMessageListenerCount, getMessageListeners, getName, isRegistered, register, register, registerMessageListener, removeDestinationEventListener, removeDestinationEventListeners, setName, unregister, unregister, unregisterMessageListener, unregisterMessageListenersprotected volatile PortalExecutorManager portalExecutorManager
protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager> serviceTracker
public void afterPropertiesSet()
afterPropertiesSet in class BaseDestinationpublic void close(boolean force)
close in interface Destinationclose in class BaseDestinationpublic void destroy()
destroy in interface Destinationdestroy in class BaseDestinationpublic DestinationStatistics getDestinationStatistics()
getDestinationStatistics in interface DestinationgetDestinationStatistics in class BaseDestinationpublic int getMaximumQueueSize()
public int getWorkersCoreSize()
public int getWorkersMaxSize()
public void open()
open in interface Destinationopen in class BaseDestinationpublic void send(Message message)
send in interface Destinationsend in class BaseDestinationpublic void setMaximumQueueSize(int maximumQueueSize)
public void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
public void setWorkersCoreSize(int workersCoreSize)
public void setWorkersMaxSize(int workersMaxSize)
protected RejectedExecutionHandler createRejectionExecutionHandler()
protected abstract void dispatch(Set<MessageListener> messageListeners, Message message)
protected ThreadPoolExecutor getThreadPoolExecutor()
protected void populateMessageFromThreadLocals(Message message)
protected void populateThreadLocalsFromMessage(Message message)