com.liferay.portal.kernel.messaging
Class BaseDestination

java.lang.Object
  com.liferay.portal.kernel.messaging.BaseDestination

All Implemented Interfaces:

Destination

Direct Known Subclasses:

ArrayDispatcherDestination, IteratorDispatcherDestination

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)
protected void	doClose(boolean force)
protected void	doOpen()
java.lang.String	getName()
protected java.util.concurrent.ThreadPoolExecutor	getThreadPoolExecutor()
protected int	getWorkersCoreSize()
protected int	getWorkersMaxSize()
void	open()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.liferay.portal.kernel.messaging.Destination

register, send, send, unregister

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

getName

public java.lang.String getName()

Specified by:

getName in interface Destination

open

public void open()

Specified by:

open in interface Destination

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()