com.liferay.portal.kernel.messaging
Class BaseDestination

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

All Implemented Interfaces:

Destination

Direct Known Subclasses:

ParallelDestination, SerialDestination

public abstract class BaseDestination
extends Object
implements Destination

Constructor Summary

BaseDestination()

BaseDestination(String name)
Deprecated.

BaseDestination(String name, int workersCoreSize, int workersMaxSize)
Deprecated.

Method Summary

void	addDestinationEventListener(DestinationEventListener destinationEventListener)
void	afterPropertiesSet()
void	close()
void	close(boolean force)
void	copyDestinationEventListeners(Destination destination)
void	copyMessageListeners(Destination destination)
protected abstract void	dispatch(Set<MessageListener> messageListeners, Message message)
protected void	doClose(boolean force)
protected void	doOpen()
protected void	fireMessageListenerRegisteredEvent(MessageListener messageListener)
protected void	fireMessageListenerUnregisteredEvent(MessageListener messageListener)
DestinationStatistics	getDestinationStatistics()
int	getMaximumQueueSize()
int	getMessageListenerCount()
String	getName()
protected ThreadPoolExecutor	getThreadPoolExecutor()
int	getWorkersCoreSize()
int	getWorkersMaxSize()
boolean	isRegistered()
void	open()
boolean	register(MessageListener messageListener)
boolean	register(MessageListener messageListener, ClassLoader classloader)
protected boolean	registerMessageListener(InvokerMessageListener invokerMessageListener)
void	removeDestinationEventListener(DestinationEventListener destinationEventListener)
void	removeDestinationEventListeners()
void	send(Message message)
void	setMaximumQueueSize(int maximumQueueSize)
void	setName(String name)
void	setWorkersCoreSize(int workersCoreSize)
void	setWorkersMaxSize(int workersMaxSize)
boolean	unregister(MessageListener messageListener)
boolean	unregister(MessageListener messageListener, ClassLoader classloader)
protected boolean	unregisterMessageListener(InvokerMessageListener invokerMessageListener)
void	unregisterMessageListeners()

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseDestination

public BaseDestination()

BaseDestination

public BaseDestination(String name)

Deprecated.

BaseDestination

public BaseDestination(String name,
                       int workersCoreSize,
                       int workersMaxSize)

Deprecated.

Method Detail

addDestinationEventListener

public void addDestinationEventListener(DestinationEventListener destinationEventListener)

Specified by:

addDestinationEventListener in interface Destination

afterPropertiesSet

public void afterPropertiesSet()

close

public void close()

Specified by:

close in interface Destination

close

public void close(boolean force)

Specified by:

close in interface Destination

copyDestinationEventListeners

public void copyDestinationEventListeners(Destination destination)

Specified by:

copyDestinationEventListeners 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

getMaximumQueueSize

public int getMaximumQueueSize()

getMessageListenerCount

public int getMessageListenerCount()

Specified by:

getMessageListenerCount in interface Destination

getName

public String getName()

Specified by:

getName in interface Destination

getWorkersCoreSize

public int getWorkersCoreSize()

getWorkersMaxSize

public int getWorkersMaxSize()

isRegistered

public boolean isRegistered()

Specified by:

isRegistered in interface Destination

open

public void open()

Specified by:

open in interface Destination

register

public boolean register(MessageListener messageListener)

Specified by:

register in interface Destination

register

public boolean register(MessageListener messageListener,
                        ClassLoader classloader)

Specified by:

register in interface Destination

removeDestinationEventListener

public void removeDestinationEventListener(DestinationEventListener destinationEventListener)

Specified by:

removeDestinationEventListener in interface Destination

removeDestinationEventListeners

public void removeDestinationEventListeners()

Specified by:

removeDestinationEventListeners in interface Destination

send

public void send(Message message)

Specified by:

send in interface Destination

setMaximumQueueSize

public void setMaximumQueueSize(int maximumQueueSize)

setName

public void setName(String name)

setWorkersCoreSize

public void setWorkersCoreSize(int workersCoreSize)

setWorkersMaxSize

public void setWorkersMaxSize(int workersMaxSize)

unregister

public boolean unregister(MessageListener messageListener)

Specified by:

unregister in interface Destination

unregister

public boolean unregister(MessageListener messageListener,
                          ClassLoader classloader)

unregisterMessageListeners

public void unregisterMessageListeners()

Specified by:

unregisterMessageListeners in interface Destination

dispatch

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

doClose

protected void doClose(boolean force)

doOpen

protected void doOpen()

fireMessageListenerRegisteredEvent

protected void fireMessageListenerRegisteredEvent(MessageListener messageListener)

fireMessageListenerUnregisteredEvent

protected void fireMessageListenerUnregisteredEvent(MessageListener messageListener)

getThreadPoolExecutor

protected ThreadPoolExecutor getThreadPoolExecutor()

registerMessageListener

protected boolean registerMessageListener(InvokerMessageListener invokerMessageListener)

unregisterMessageListener

protected boolean unregisterMessageListener(InvokerMessageListener invokerMessageListener)