Liferay 7.0-ce-b4

com.liferay.portal.kernel.messaging
Class MessageBusUtil

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

public class MessageBusUtil
extends Object


Constructor Summary
MessageBusUtil()
           
 
Method Summary
static void addDestination(Destination destination)
           
static Message createResponseMessage(Message requestMessage)
           
static Message createResponseMessage(Message requestMessage, Object payload)
           
static Destination getDestination(String destinationName)
           
static MessageBusUtil getInstance()
           
static MessageBus getMessageBus()
           
static boolean hasMessageListener(String destination)
           
static void registerMessageListener(String destinationName, MessageListener messageListener)
           
static void removeDestination(String destinationName)
           
static void sendMessage(String destinationName, Message message)
           
static void sendMessage(String destinationName, Object payload)
           
static Object sendSynchronousMessage(String destinationName, Message message)
           
static Object sendSynchronousMessage(String destinationName, Message message, long timeout)
           
static Object sendSynchronousMessage(String destinationName, Object payload)
           
static Object sendSynchronousMessage(String destinationName, Object payload, long timeout)
           
static Object sendSynchronousMessage(String destinationName, Object payload, String responseDestinationName)
           
static Object sendSynchronousMessage(String destinationName, Object payload, String responseDestinationName, long timeout)
           
 void setSynchronousMessageSenderMode(SynchronousMessageSender.Mode synchronousMessageSenderMode)
           
static void shutdown()
           
static void shutdown(boolean force)
           
static boolean unregisterMessageListener(String destinationName, MessageListener messageListener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageBusUtil

public MessageBusUtil()
Method Detail

addDestination

public static void addDestination(Destination destination)

createResponseMessage

public static Message createResponseMessage(Message requestMessage)

createResponseMessage

public static Message createResponseMessage(Message requestMessage,
                                            Object payload)

getDestination

public static Destination getDestination(String destinationName)

getInstance

public static MessageBusUtil getInstance()

getMessageBus

public static MessageBus getMessageBus()

hasMessageListener

public static boolean hasMessageListener(String destination)

registerMessageListener

public static void registerMessageListener(String destinationName,
                                           MessageListener messageListener)

removeDestination

public static void removeDestination(String destinationName)

sendMessage

public static void sendMessage(String destinationName,
                               Message message)

sendMessage

public static void sendMessage(String destinationName,
                               Object payload)

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Message message)
                                     throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Message message,
                                            long timeout)
                                     throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Object payload)
                                     throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Object payload,
                                            long timeout)
                                     throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Object payload,
                                            String responseDestinationName)
                                     throws MessageBusException
Throws:
MessageBusException

sendSynchronousMessage

public static Object sendSynchronousMessage(String destinationName,
                                            Object payload,
                                            String responseDestinationName,
                                            long timeout)
                                     throws MessageBusException
Throws:
MessageBusException

shutdown

public static void shutdown()

shutdown

public static void shutdown(boolean force)

unregisterMessageListener

public static boolean unregisterMessageListener(String destinationName,
                                                MessageListener messageListener)

setSynchronousMessageSenderMode

public void setSynchronousMessageSenderMode(SynchronousMessageSender.Mode synchronousMessageSenderMode)

Liferay 7.0-ce-b4