Modifier and Type | Method and Description |
---|---|
void |
BackgroundTaskStatusMessageSender.sendBackgroundTaskStatusMessage(Message message) |
void |
BackgroundTaskStatusMessageTranslator.translate(BackgroundTaskStatus backgroundTaskStatus,
Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
ClusterLinkUtil.setAddress(Message message,
Address address) |
Modifier and Type | Method and Description |
---|---|
static Address |
ClusterLinkUtil.getAddress(Message message) |
static void |
ClusterLinkUtil.sendMulticastMessage(Message message,
Priority priority) |
void |
ClusterLink.sendMulticastMessage(Message message,
Priority priority) |
static void |
ClusterLinkUtil.sendUnicastMessage(Address address,
Message message,
Priority priority) |
void |
ClusterLink.sendUnicastMessage(Address address,
Message message,
Priority priority) |
static Message |
ClusterLinkUtil.setAddress(Message message,
Address address) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterBridgeMessageListener.doReceive(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
LicenseManagerMessageType.createMessage() |
Message |
LicenseManagerMessageType.createMessage(LCSPortletState lcsPortletState) |
Modifier and Type | Method and Description |
---|---|
static JSONObject |
LicenseManagerMessageType.getMessagePayload(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
Message.clone() |
static Message |
MessageBusUtil.createResponseMessage(Message requestMessage) |
static Message |
MessageBusUtil.createResponseMessage(Message requestMessage,
Object payload) |
static Message |
Message.fromByteArray(byte[] bytes) |
Message |
MessageRunnable.getMessage() |
Modifier and Type | Method and Description |
---|---|
List<Message> |
MessageBatch.getMessages() |
Modifier and Type | Method and Description |
---|---|
void |
MessageBatch.addMessage(Message message) |
void |
Message.copyFrom(Message message) |
void |
Message.copyTo(Message message) |
static Message |
MessageBusUtil.createResponseMessage(Message requestMessage) |
static Message |
MessageBusUtil.createResponseMessage(Message requestMessage,
Object payload) |
protected void |
SerialDestination.dispatch(Set<MessageListener> messageListeners,
Message message) |
protected abstract void |
BaseAsyncDestination.dispatch(Set<MessageListener> messageListeners,
Message message) |
protected void |
ParallelDestination.dispatch(Set<MessageListener> messageListeners,
Message message) |
protected void |
HotDeployMessageListener.doReceive(Message message) |
protected abstract void |
BaseMessageListener.doReceive(Message message) |
protected abstract void |
BaseMessageStatusMessageListener.doReceive(Message message,
MessageStatus messageStatus) |
protected void |
HotDeployMessageListener.onDeploy(Message message) |
protected void |
HotDeployMessageListener.onUndeploy(Message message) |
protected void |
BaseAsyncDestination.populateMessageFromThreadLocals(Message message) |
protected void |
BaseAsyncDestination.populateThreadLocalsFromMessage(Message message) |
void |
BridgingMessageListener.receive(Message message)
Deprecated.
|
void |
BaseMessageListener.receive(Message message) |
void |
InvokerMessageListener.receive(Message message) |
void |
MessageListener.receive(Message message) |
void |
BaseMessageStatusMessageListener.receive(Message message) |
void |
DummyMessageListener.receive(Message message) |
void |
BaseDestination.send(Message message) |
void |
SynchronousDestination.send(Message message) |
void |
BaseAsyncDestination.send(Message message) |
void |
Destination.send(Message message) |
void |
DestinationWrapper.send(Message message) |
static void |
MessageBusUtil.sendMessage(String destinationName,
Message message) |
void |
MessageBus.sendMessage(String destinationName,
Message message) |
static Object |
MessageBusUtil.sendSynchronousMessage(String destinationName,
Message message) |
static Object |
MessageBusUtil.sendSynchronousMessage(String destinationName,
Message message,
long timeout) |
Constructor and Description |
---|
MessageRunnable(Message message) |
Modifier and Type | Method and Description |
---|---|
protected Message |
BaseMultiDestinationProxyBean.buildMessage(ProxyRequest proxyRequest) |
protected Message |
BaseProxyBean.buildMessage(ProxyRequest proxyRequest) |
Modifier and Type | Method and Description |
---|---|
static void |
MessageValuesThreadLocal.populateMessageFromThreadLocals(Message message) |
static void |
MessageValuesThreadLocal.populateThreadLocalsFromMessage(Message message) |
void |
ProxyMessageListener.receive(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
SingleDestinationMessageSender.send(Message message)
Deprecated.
|
Object |
SingleDestinationSynchronousMessageSender.send(Message message)
Deprecated.
|
Object |
SingleDestinationSynchronousMessageSender.send(Message message,
long timeout)
Deprecated.
|
Object |
SynchronousMessageSender.send(String destinationName,
Message message) |
Object |
SynchronousMessageSender.send(String destinationName,
Message message,
long timeout) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageRoutingBag.getMessage() |
Modifier and Type | Method and Description |
---|---|
void |
IntrabandBridgeMessageListener.receive(Message message) |
void |
IntrabandBridgeDestination.send(Message message) |
void |
MessageRoutingBag.setMessage(Message message) |
Constructor and Description |
---|
MessageRoutingBag(Message message,
boolean synchronizedBridge) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultPollerResponse.close(Message message,
PollerHeader pollerHeader,
String portletId,
String chunkId) |
void |
PollerResponse.close(Message message,
PollerHeader pollerHeader,
String portletId,
String chunkId) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerEngineHelper.auditSchedulerJobs(Message message,
TriggerState triggerState) |
static void |
SchedulerEngineHelperUtil.auditSchedulerJobs(Message message,
TriggerState triggerState) |
void |
SchedulerEngineHelper.schedule(Trigger trigger,
StorageType storageType,
String description,
String destinationName,
Message message,
int exceptionsMaxSize) |
static void |
SchedulerEngineHelperUtil.schedule(Trigger trigger,
StorageType storageType,
String description,
String destinationName,
Message message,
int exceptionsMaxSize) |
void |
SchedulerEngine.schedule(Trigger trigger,
String description,
String destinationName,
Message message,
StorageType storageType) |
Modifier and Type | Method and Description |
---|---|
Message |
SchedulerResponse.getMessage() |
Modifier and Type | Method and Description |
---|---|
protected void |
SchedulerEventMessageListenerWrapper.handleException(Message message,
Exception exception) |
void |
SchedulerEventMessageListenerWrapper.receive(Message message) |
void |
SchedulerResponse.setMessage(Message message) |