Liferay 6.2-ce-ga5

com.liferay.portal.kernel.messaging
Class BaseAsyncDestination

java.lang.Object
  extended by com.liferay.portal.kernel.messaging.BaseDestination
      extended by com.liferay.portal.kernel.messaging.BaseAsyncDestination
All Implemented Interfaces:
Destination
Direct Known Subclasses:
ParallelDestination, SerialDestination

public abstract class BaseAsyncDestination
extends BaseDestination


Field Summary
 
Fields inherited from class com.liferay.portal.kernel.messaging.BaseDestination
messageListeners, name
 
Constructor Summary
BaseAsyncDestination()
           
BaseAsyncDestination(String name)
          Deprecated. As of 6.1.0
BaseAsyncDestination(String name, int workersCoreSize, int workersMaxSize)
          Deprecated. As of 6.1.0
 
Method Summary
 void close(boolean force)
           
protected  RejectedExecutionHandler createRejectionExecutionHandler()
           
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)
           
 
Methods inherited from class com.liferay.portal.kernel.messaging.BaseDestination
addDestinationEventListener, afterPropertiesSet, 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
 

Constructor Detail

BaseAsyncDestination

public BaseAsyncDestination()

BaseAsyncDestination

public BaseAsyncDestination(String name)
Deprecated. As of 6.1.0


BaseAsyncDestination

public BaseAsyncDestination(String name,
                            int workersCoreSize,
                            int workersMaxSize)
Deprecated. As of 6.1.0

Method Detail

close

public void close(boolean force)
Specified by:
close in interface Destination
Overrides:
close in class BaseDestination

getDestinationStatistics

public DestinationStatistics getDestinationStatistics()

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)

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)

Liferay 6.2-ce-ga5