com.liferay.portal.kernel.messaging
Class BaseDestination

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

public abstract class BaseDestination
extends java.lang.Object
implements Destination

View Source

Author:
Michael C. Han

Constructor Summary
BaseDestination(java.lang.String name)
           
BaseDestination(java.lang.String name, int workersCoreSize, int workersMaxSize)
           
 
Method Summary
 void close()
           
 void close(boolean force)
           
 void copyMessageListeners(Destination destination)
           
protected abstract  void dispatch(java.util.Set<MessageListener> messageListeners, Message message)
           
protected  void doClose(boolean force)
           
protected  void doOpen()
           
 DestinationStatistics getDestinationStatistics()
           
 int getMessageListenerCount()
           
 java.lang.String getName()
           
protected  java.util.concurrent.ThreadPoolExecutor getThreadPoolExecutor()
           
protected  int getWorkersCoreSize()
           
protected  int getWorkersMaxSize()
           
 boolean isRegistered()
           
 void open()
           
 void register(MessageListener messageListener)
           
 void register(MessageListener messageListener, java.lang.ClassLoader classloader)
           
 void send(Message message)
           
 boolean unregister(MessageListener messageListener)
           
 boolean unregister(MessageListener messageListener, java.lang.ClassLoader classloader)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BaseDestination

public BaseDestination(java.lang.String name)

BaseDestination

public BaseDestination(java.lang.String name,
                       int workersCoreSize,
                       int workersMaxSize)
Method Detail

close

public void close()
Specified by:
close in interface Destination

close

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

copyMessageListeners

public void copyMessageListeners(Destination destination)
Specified by:
copyMessageListeners in interface Destination

getDestinationStatistics

public DestinationStatistics getDestinationStatistics()
Specified by:
getDestinationStatistics in interface Destination

getMessageListenerCount

public int getMessageListenerCount()
Specified by:
getMessageListenerCount in interface Destination

getName

public java.lang.String getName()
Specified by:
getName in interface Destination

isRegistered

public boolean isRegistered()
Specified by:
isRegistered in interface Destination

open

public void open()
Specified by:
open in interface Destination

register

public void register(MessageListener messageListener)
Specified by:
register in interface Destination

register

public void register(MessageListener messageListener,
                     java.lang.ClassLoader classloader)
Specified by:
register in interface Destination

send

public void send(Message message)
Specified by:
send in interface Destination

unregister

public boolean unregister(MessageListener messageListener)
Specified by:
unregister in interface Destination

unregister

public boolean unregister(MessageListener messageListener,
                          java.lang.ClassLoader classloader)

dispatch

protected abstract void dispatch(java.util.Set<MessageListener> messageListeners,
                                 Message message)

doClose

protected void doClose(boolean force)

doOpen

protected void doOpen()

getThreadPoolExecutor

protected java.util.concurrent.ThreadPoolExecutor getThreadPoolExecutor()

getWorkersCoreSize

protected int getWorkersCoreSize()

getWorkersMaxSize

protected int getWorkersMaxSize()