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, unregisterMessageListeners
public void afterPropertiesSet()
afterPropertiesSet
in class BaseDestination
public void close(boolean force)
close
in interface Destination
close
in class BaseDestination
public DestinationStatistics getDestinationStatistics()
getDestinationStatistics
in interface Destination
getDestinationStatistics
in class BaseDestination
public int getMaximumQueueSize()
public int getWorkersCoreSize()
public int getWorkersMaxSize()
public void open()
open
in interface Destination
open
in class BaseDestination
public void send(Message message)
send
in interface Destination
send
in class BaseDestination
public 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)