com.liferay.portal.messaging
Class PortalMessageBus

java.lang.Object
  extended by 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 destroy()
           
 void registerMessageListener(java.lang.String destination, com.liferay.portal.kernel.messaging.MessageListener listener)
           
 void removeDestination(java.lang.String destination)
           
 void sendMessage(java.lang.String destination, java.lang.Object message)
           
 void sendMessage(java.lang.String destination, java.lang.String message)
           
 java.lang.Object sendSynchronizedMessage(java.lang.String destination, com.liferay.portal.kernel.messaging.Message message, long timeout)
           
 java.lang.String sendSynchronizedMessage(java.lang.String destination, java.lang.String message, long timeout)
           
 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

destroy

public void destroy()
             throws java.lang.Exception
Specified by:
destroy in interface org.springframework.beans.factory.DisposableBean
Throws:
java.lang.Exception

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

sendMessage

public void sendMessage(java.lang.String destination,
                        java.lang.Object message)
Specified by:
sendMessage in interface com.liferay.portal.kernel.messaging.MessageBus

sendMessage

public void sendMessage(java.lang.String destination,
                        java.lang.String message)
Specified by:
sendMessage in interface com.liferay.portal.kernel.messaging.MessageBus

sendSynchronizedMessage

public java.lang.Object sendSynchronizedMessage(java.lang.String destination,
                                                com.liferay.portal.kernel.messaging.Message message,
                                                long timeout)
                                         throws com.liferay.portal.kernel.messaging.MessageBusException
Specified by:
sendSynchronizedMessage in interface com.liferay.portal.kernel.messaging.MessageBus
Throws:
com.liferay.portal.kernel.messaging.MessageBusException

sendSynchronizedMessage

public java.lang.String sendSynchronizedMessage(java.lang.String destination,
                                                java.lang.String message,
                                                long timeout)
                                         throws com.liferay.portal.kernel.messaging.MessageBusException
Specified by:
sendSynchronizedMessage in interface com.liferay.portal.kernel.messaging.MessageBus
Throws:
com.liferay.portal.kernel.messaging.MessageBusException

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