com.liferay.portal.kernel.messaging
Class IteratorDispatcherDestination

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

All Implemented Interfaces:

Destination

Direct Known Subclasses:

TempDestination

public abstract class IteratorDispatcherDestination
extends BaseDestination

View Source

Author:

Michael C. Han, Brian Wing Shun Chan

Constructor Summary

IteratorDispatcherDestination(java.lang.String name)

IteratorDispatcherDestination(java.lang.String name, int workersCoreSize, int workersMaxSize)

Method Summary

protected abstract void	dispatch(java.util.Iterator<MessageListener> listenersItr, java.lang.Object message)
protected abstract void	dispatch(java.util.Iterator<MessageListener> listenersItr, java.lang.String message)
void	register(MessageListener listener)
void	send(java.lang.Object message)
void	send(java.lang.String message)
boolean	unregister(MessageListener listener)

Methods inherited from class com.liferay.portal.kernel.messaging.BaseDestination

close, close, doClose, doOpen, getName, getThreadPoolExecutor, getWorkersCoreSize, getWorkersMaxSize, open

Methods inherited from class java.lang.Object

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

Constructor Detail

IteratorDispatcherDestination

public IteratorDispatcherDestination(java.lang.String name)

IteratorDispatcherDestination

public IteratorDispatcherDestination(java.lang.String name,
                                     int workersCoreSize,
                                     int workersMaxSize)

Method Detail

register

public void register(MessageListener listener)

send

public void send(java.lang.Object message)

send

public void send(java.lang.String message)

unregister

public boolean unregister(MessageListener listener)

dispatch

protected abstract void dispatch(java.util.Iterator<MessageListener> listenersItr,
                                 java.lang.Object message)

dispatch

protected abstract void dispatch(java.util.Iterator<MessageListener> listenersItr,
                                 java.lang.String message)