com.liferay.portal.kernel.messaging
Interface MessageBus

All Known Implementing Classes:

DefaultMessageBus

public interface MessageBus

View Source

Author:

Michael C. Han

Method Summary

void	addDestination(Destination 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)

Method Detail

addDestination

void addDestination(Destination destination)

registerMessageListener

void registerMessageListener(java.lang.String destination,
                             MessageListener listener)

removeDestination

void removeDestination(java.lang.String destination)

sendMessage

void sendMessage(java.lang.String destination,
                 java.lang.Object message)

sendMessage

void sendMessage(java.lang.String destination,
                 java.lang.String message)

sendSynchronizedMessage

java.lang.Object sendSynchronizedMessage(java.lang.String destination,
                                         Message message,
                                         long timeout)
                                         throws MessageBusException

Throws:

MessageBusException

sendSynchronizedMessage

java.lang.String sendSynchronizedMessage(java.lang.String destination,
                                         java.lang.String message,
                                         long timeout)
                                         throws MessageBusException

Throws:

MessageBusException

shutdown

void shutdown()

shutdown

void shutdown(boolean force)

unregisterMessageListener

boolean unregisterMessageListener(java.lang.String destination,
                                  MessageListener listener)