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 |
Message.clone() |
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) |
protected abstract void |
BaseMessageListener.doReceive(Message message) |
protected void |
HotDeployMessageListener.doReceive(Message message) |
protected void |
BaseMessageListener.doReceive(Message message,
long companyId) |
boolean |
MessageBusInterceptor.intercept(MessageBus messageBus,
String destinationName,
Message message) |
protected void |
HotDeployMessageListener.onDeploy(Message message) |
protected void |
HotDeployMessageListener.onUndeploy(Message message) |
void |
BaseMessageListener.receive(Message message) |
void |
MessageListener.receive(Message message) |
void |
DummyMessageListener.receive(Message message) |
void |
InvokerMessageListener.receive(Message message) |
void |
BaseDestination.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) |
Constructor and Description |
---|
MessageRunnable(Message message) |
Modifier and Type | Method and Description |
---|---|
default com.liferay.petra.function.UnsafeConsumer<Message,Exception> |
SchedulerJobConfiguration.getJobExecutorUnsafeConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerEngineHelper.auditSchedulerJobs(Message message,
TriggerState triggerState) |
void |
SchedulerEngineHelper.schedule(Trigger trigger,
StorageType storageType,
String description,
String destinationName,
Message message) |
static void |
SchedulerEngineHelperUtil.schedule(Trigger trigger,
StorageType storageType,
String description,
String destinationName,
Message message) |
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 |
---|---|
void |
SchedulerResponse.setMessage(Message message) |