com.liferay.portal.kernel.messaging
Class MessageBusUtil

java.lang.Object
  com.liferay.portal.kernel.messaging.MessageBusUtil

public class MessageBusUtil
extends java.lang.Object

View Source

Author:

Michael C. Han

Method Summary

static void	addDestination(Destination destination)
static MessageBus	getMessageBus()
static MessageSender	getMessageSender()
static void	init(MessageBus messageBus, MessageSender messageSender)
static void	registerMessageListener(java.lang.String destination, MessageListener listener)
static void	removeDestination(java.lang.String destination)
static void	sendMessage(java.lang.String destination, java.lang.Object message)
static void	sendMessage(java.lang.String destination, java.lang.String message)
static java.lang.Object	sendSynchronizedMessage(java.lang.String destination, Message message)
static java.lang.Object	sendSynchronizedMessage(java.lang.String destination, Message message, long timeout)
static java.lang.String	sendSynchronizedMessage(java.lang.String destination, java.lang.String message)
static java.lang.String	sendSynchronizedMessage(java.lang.String destination, java.lang.String message, long timeout)
static 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

Method Detail

addDestination

public static void addDestination(Destination destination)

getMessageBus

public static MessageBus getMessageBus()

getMessageSender

public static MessageSender getMessageSender()

init

public static void init(MessageBus messageBus,
                        MessageSender messageSender)

registerMessageListener

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

removeDestination

public static void removeDestination(java.lang.String destination)

sendMessage

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

sendMessage

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

sendSynchronizedMessage

public static java.lang.Object sendSynchronizedMessage(java.lang.String destination,
                                                       Message message)
                                                throws MessageBusException

Throws:

MessageBusException

sendSynchronizedMessage

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

Throws:

MessageBusException

sendSynchronizedMessage

public static java.lang.String sendSynchronizedMessage(java.lang.String destination,
                                                       java.lang.String message)
                                                throws MessageBusException

Throws:

MessageBusException

sendSynchronizedMessage

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

Throws:

MessageBusException

unregisterMessageListener

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