com.liferay.portal.messaging.internal.BaseAsyncDestination@Deprecated public abstract class BaseAsyncDestination extends BaseDestination
| Modifier and Type | Field and Description |
|---|---|
protected PortalExecutorManager |
portalExecutorManager
Deprecated.
|
protected com.liferay.registry.ServiceTracker<PortalExecutorManager,PortalExecutorManager> |
serviceTracker
Deprecated.
|
messageListeners, name| Constructor and Description |
|---|
BaseAsyncDestination()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet()
Deprecated.
|
void |
close(boolean force)
Deprecated.
|
protected RejectedExecutionHandler |
createRejectionExecutionHandler()
Deprecated.
As of Judson (7.1.x), with no direct replacement
|
void |
destroy()
Deprecated.
|
protected abstract void |
dispatch(Set<MessageListener> messageListeners,
Message message)
Deprecated.
|
DestinationStatistics |
getDestinationStatistics()
Deprecated.
|
int |
getMaximumQueueSize()
Deprecated.
|
protected ThreadPoolExecutor |
getThreadPoolExecutor()
Deprecated.
As of Judson (7.1.x), with no direct replacement
|
int |
getWorkersCoreSize()
Deprecated.
|
int |
getWorkersMaxSize()
Deprecated.
|
void |
open()
Deprecated.
|
protected void |
populateMessageFromThreadLocals(Message message)
Deprecated.
|
protected void |
populateThreadLocalsFromMessage(Message message)
Deprecated.
|
void |
send(Message message)
Deprecated.
|
void |
setMaximumQueueSize(int maximumQueueSize)
Deprecated.
|
void |
setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
Deprecated.
As of Judson (7.1.x), with no direct replacement
|
void |
setWorkersCoreSize(int workersCoreSize)
Deprecated.
|
void |
setWorkersMaxSize(int workersMaxSize)
Deprecated.
|
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)
@Deprecated public void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
public void setWorkersCoreSize(int workersCoreSize)
public void setWorkersMaxSize(int workersMaxSize)
@Deprecated protected RejectedExecutionHandler createRejectionExecutionHandler()
protected abstract void dispatch(Set<MessageListener> messageListeners, Message message)
@Deprecated protected ThreadPoolExecutor getThreadPoolExecutor()
protected void populateMessageFromThreadLocals(Message message)
protected void populateThreadLocalsFromMessage(Message message)