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