com.liferay.portal.kernel.messaging
Class MessageBusUtil

java.lang.Object
  extended by 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 Message createResponseMessage(Message requestMessage)
           
static Message createResponseMessage(Message requestMessage, java.lang.Object payload)
           
static MessageBus getMessageBus()
           
static MessageSender getMessageSender()
           
static boolean hasMessageListener(java.lang.String destination)
           
static void init(MessageBus messageBus, MessageSender messageSender, SynchronousMessageSender synchronousMessageSender)
           
static void registerMessageListener(java.lang.String destination, MessageListener listener)
           
static void removeDestination(java.lang.String destination)
           
static void sendMessage(java.lang.String destination, Message message)
           
static void sendMessage(java.lang.String destination, java.lang.Object payload)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, Message message)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, Message message, long timeout)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, java.lang.Object payload)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, java.lang.Object payload, long timeout)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, java.lang.Object payload, java.lang.String responseDestination)
           
static java.lang.Object sendSynchronousMessage(java.lang.String destination, java.lang.Object payload, java.lang.String responseDestination, 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)

createResponseMessage

public static Message createResponseMessage(Message requestMessage)

createResponseMessage

public static Message createResponseMessage(Message requestMessage,
                                            java.lang.Object payload)

getMessageBus

public static MessageBus getMessageBus()

getMessageSender

public static MessageSender getMessageSender()

hasMessageListener

public static boolean hasMessageListener(java.lang.String destination)

init

public static void init(MessageBus messageBus,
                        MessageSender messageSender,
                        SynchronousMessageSender synchronousMessageSender)

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,
                               Message message)

sendMessage

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

sendSynchronousMessage

public static java.lang.Object sendSynchronousMessage(java.lang.String destination,
                                                      Message message)
                                               throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

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

sendSynchronousMessage

public static java.lang.Object sendSynchronousMessage(java.lang.String destination,
                                                      java.lang.Object payload)
                                               throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static java.lang.Object sendSynchronousMessage(java.lang.String destination,
                                                      java.lang.Object payload,
                                                      long timeout)
                                               throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static java.lang.Object sendSynchronousMessage(java.lang.String destination,
                                                      java.lang.Object payload,
                                                      java.lang.String responseDestination)
                                               throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static java.lang.Object sendSynchronousMessage(java.lang.String destination,
                                                      java.lang.Object payload,
                                                      java.lang.String responseDestination,
                                                      long timeout)
                                               throws MessageBusException
Throws:
MessageBusException

unregisterMessageListener

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