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 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 |
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)