com.liferay.portal.kernel.messaging
Class DefaultMessageBus
java.lang.Object
com.liferay.portal.kernel.messaging.DefaultMessageBus
- All Implemented Interfaces:
- MessageBus
public class DefaultMessageBus
- extends java.lang.Object
- implements MessageBus
View Source
- Author:
- Michael C. Han
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultMessageBus
public DefaultMessageBus()
addDestination
public void addDestination(Destination destination)
- Specified by:
addDestination in interface MessageBus
registerMessageListener
public void registerMessageListener(java.lang.String destination,
MessageListener listener)
- Specified by:
registerMessageListener in interface MessageBus
removeDestination
public void removeDestination(java.lang.String destination)
- Specified by:
removeDestination in interface MessageBus
sendMessage
public void sendMessage(java.lang.String destination,
java.lang.Object message)
- Specified by:
sendMessage in interface MessageBus
sendMessage
public void sendMessage(java.lang.String destination,
java.lang.String message)
- Specified by:
sendMessage in interface MessageBus
sendSynchronizedMessage
public java.lang.Object sendSynchronizedMessage(java.lang.String destination,
Message message,
long timeout)
throws MessageBusException
- Specified by:
sendSynchronizedMessage in interface MessageBus
- Throws:
MessageBusException
sendSynchronizedMessage
public java.lang.String sendSynchronizedMessage(java.lang.String destination,
java.lang.String message,
long timeout)
throws MessageBusException
- Specified by:
sendSynchronizedMessage in interface MessageBus
- Throws:
MessageBusException
shutdown
public void shutdown()
- Specified by:
shutdown in interface MessageBus
shutdown
public void shutdown(boolean force)
- Specified by:
shutdown in interface MessageBus
unregisterMessageListener
public boolean unregisterMessageListener(java.lang.String destination,
MessageListener listener)
- Specified by:
unregisterMessageListener in interface MessageBus
getNextResponseId
protected java.lang.String getNextResponseId()
getResponseDestination
protected java.lang.String getResponseDestination(java.lang.String destination)
getResponseDestination
protected Destination getResponseDestination(Destination destination)