com.liferay.portal.messaging
Class PortalMessageBus

java.lang.Object
  com.liferay.portal.messaging.PortalMessageBus

All Implemented Interfaces:

com.liferay.portal.kernel.messaging.MessageBus, org.springframework.beans.factory.DisposableBean

public class PortalMessageBus
extends java.lang.Object
implements org.springframework.beans.factory.DisposableBean, com.liferay.portal.kernel.messaging.MessageBus

View Source

Author:

Michael C. Han, Brian Wing Shun Chan

Constructor Summary

PortalMessageBus()

Method Summary

void	addDestination(com.liferay.portal.kernel.messaging.Destination destination)
void	addDestinationEventListener(com.liferay.portal.kernel.messaging.DestinationEventListener listener)
void	destroy()
boolean	hasDestination(java.lang.String destination)
boolean	hasMessageListener(java.lang.String destination)
void	registerMessageListener(java.lang.String destination, com.liferay.portal.kernel.messaging.MessageListener listener)
void	removeDestination(java.lang.String destination)
void	removeDestinationEventListener(com.liferay.portal.kernel.messaging.DestinationEventListener listener)
void	sendMessage(java.lang.String destination, com.liferay.portal.kernel.messaging.Message message)
void	setMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus)
void	shutdown()
void	shutdown(boolean force)
boolean	unregisterMessageListener(java.lang.String destination, com.liferay.portal.kernel.messaging.MessageListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

PortalMessageBus

public PortalMessageBus()

Method Detail

addDestination

public void addDestination(com.liferay.portal.kernel.messaging.Destination destination)

Specified by:

addDestination in interface com.liferay.portal.kernel.messaging.MessageBus

addDestinationEventListener

public void addDestinationEventListener(com.liferay.portal.kernel.messaging.DestinationEventListener listener)

Specified by:

addDestinationEventListener in interface com.liferay.portal.kernel.messaging.MessageBus

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception

hasDestination

public boolean hasDestination(java.lang.String destination)

Specified by:

hasDestination in interface com.liferay.portal.kernel.messaging.MessageBus

hasMessageListener

public boolean hasMessageListener(java.lang.String destination)

Specified by:

hasMessageListener in interface com.liferay.portal.kernel.messaging.MessageBus

registerMessageListener

public void registerMessageListener(java.lang.String destination,
                                    com.liferay.portal.kernel.messaging.MessageListener listener)

Specified by:

registerMessageListener in interface com.liferay.portal.kernel.messaging.MessageBus

removeDestination

public void removeDestination(java.lang.String destination)

Specified by:

removeDestination in interface com.liferay.portal.kernel.messaging.MessageBus

removeDestinationEventListener

public void removeDestinationEventListener(com.liferay.portal.kernel.messaging.DestinationEventListener listener)

Specified by:

removeDestinationEventListener in interface com.liferay.portal.kernel.messaging.MessageBus

sendMessage

public void sendMessage(java.lang.String destination,
                        com.liferay.portal.kernel.messaging.Message message)

Specified by:

sendMessage in interface com.liferay.portal.kernel.messaging.MessageBus

setMessageBus

public void setMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus)

unregisterMessageListener

public boolean unregisterMessageListener(java.lang.String destination,
                                         com.liferay.portal.kernel.messaging.MessageListener listener)

Specified by:

unregisterMessageListener in interface com.liferay.portal.kernel.messaging.MessageBus

shutdown

public void shutdown()

Specified by:

shutdown in interface com.liferay.portal.kernel.messaging.MessageBus

shutdown

public void shutdown(boolean force)

Specified by:

shutdown in interface com.liferay.portal.kernel.messaging.MessageBus