com.liferay.portal.kernel.messaging

Class MessageBusUtil

Object

com.liferay.portal.kernel.messaging.MessageBusUtil

public class MessageBusUtil
extends Object

Author:

Michael C. Han, Raymond Augé

Constructor Summary

Constructors

Constructor and Description
MessageBusUtil()

Method Summary

Modifier and Type	Method and Description
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() Deprecated. As of Judson (7.1.x), with no direct replacement
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 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

@Deprecated
public static MessageBusUtil getInstance()

Deprecated. As of Judson (7.1.x), with no direct replacement

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)