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

Constructor Summary

DefaultMessageBus()

Method Summary

void	addDestination(Destination destination)
protected java.lang.String	getNextResponseId()
protected Destination	getResponseDestination(Destination destination)
protected java.lang.String	getResponseDestination(java.lang.String destination)
void	registerMessageListener(java.lang.String destination, 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, Message message, long timeout)
java.lang.String	sendSynchronizedMessage(java.lang.String destination, java.lang.String message, long timeout)
void	shutdown()
void	shutdown(boolean force)
boolean	unregisterMessageListener(java.lang.String destination, MessageListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMessageBus

public DefaultMessageBus()

Method Detail

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)