com.liferay.portal.messaging.internal.BaseAsyncDestination@Deprecated public abstract class BaseAsyncDestination extends BaseDestination
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
|
protected abstract void |
dispatch(Set<MessageListener> messageListeners,
Message message)
Deprecated.
|
protected void |
execute(Runnable runnable)
Deprecated.
|
DestinationStatistics |
getDestinationStatistics()
Deprecated.
|
int |
getMaximumQueueSize()
Deprecated.
|
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.
|
void |
setWorkersCoreSize(int workersCoreSize)
Deprecated.
|
void |
setWorkersMaxSize(int workersMaxSize)
Deprecated.
|
addDestinationEventListener, close, copyDestinationEventListeners, copyMessageListeners, destroy, fireMessageListenerRegisteredEvent, fireMessageListenerUnregisteredEvent, getDestinationType, getMessageListenerCount, getMessageListeners, getName, isRegistered, register, register, registerMessageListener, removeDestinationEventListener, removeDestinationEventListeners, setDestinationType, setName, unregister, unregister, unregisterMessageListener, unregisterMessageListenerspublic void afterPropertiesSet()
afterPropertiesSet in class BaseDestinationpublic void close(boolean force)
close in interface Destinationclose 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)
@Deprecated protected RejectedExecutionHandler createRejectionExecutionHandler()
protected abstract void dispatch(Set<MessageListener> messageListeners, Message message)
protected void execute(Runnable runnable)
protected void populateMessageFromThreadLocals(Message message)
protected void populateThreadLocalsFromMessage(Message message)