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 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 destinationName,
MessageListener messageListener)
|
static void |
removeDestination(java.lang.String destinationName)
|
static void |
sendMessage(java.lang.String destinationName,
Message message)
|
static void |
sendMessage(java.lang.String destinationName,
java.lang.Object payload)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
Message message)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
Message message,
long timeout)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
long timeout)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
java.lang.String responseDestinationName)
|
static java.lang.Object |
sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
java.lang.String responseDestinationName,
long timeout)
|
static boolean |
unregisterMessageListener(java.lang.String destinationName,
MessageListener messageListener)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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 destinationName,
MessageListener messageListener)
removeDestination
public static void removeDestination(java.lang.String destinationName)
sendMessage
public static void sendMessage(java.lang.String destinationName,
Message message)
sendMessage
public static void sendMessage(java.lang.String destinationName,
java.lang.Object payload)
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
Message message)
throws MessageBusException
- Throws:
MessageBusException
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
Message message,
long timeout)
throws MessageBusException
- Throws:
MessageBusException
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload)
throws MessageBusException
- Throws:
MessageBusException
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
long timeout)
throws MessageBusException
- Throws:
MessageBusException
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
java.lang.String responseDestinationName)
throws MessageBusException
- Throws:
MessageBusException
sendSynchronousMessage
public static java.lang.Object sendSynchronousMessage(java.lang.String destinationName,
java.lang.Object payload,
java.lang.String responseDestinationName,
long timeout)
throws MessageBusException
- Throws:
MessageBusException
unregisterMessageListener
public static boolean unregisterMessageListener(java.lang.String destinationName,
MessageListener messageListener)