Package | Description |
---|---|
com.solace.messaging.publisher |
A package that contains interfaces and classes to handle publishing messages.
|
com.solace.messaging.receiver |
A package that contains interfaces and classes to handle receiving messages.
|
Modifier and Type | Method and Description |
---|---|
InboundMessage |
RequestReplyMessagePublisher.publishAwaitResponse(OutboundMessage requestMessage,
Properties additionalMessageProperties,
Topic requestDestination,
long replyTimeout)
Sends a request message return response message that blocks until a response is received or a
timeout occurs.
|
InboundMessage |
RequestReplyMessagePublisher.publishAwaitResponse(OutboundMessage requestMessage,
Topic requestDestination,
long replyTimeout)
Sends a request message return response message that blocks until a response is received or a
timeout occurs.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestReplyMessagePublisher.ReplyMessageHandler.onMessage(InboundMessage message,
Object userContext,
PubSubPlusClientException exception)
The callback to handle a reply message.
|
Modifier and Type | Method and Description |
---|---|
InboundMessage |
RequestReplyMessageReceiver.FailedReplyEvent.getRequestMessage()
Retrieves a request message that's associated with a given event.
|
InboundMessage |
PersistentMessageReceiver.receiveMessage()
Blocking request to receive a next message.
|
InboundMessage |
MessageQueueBrowser.receiveMessage()
Blocking request to receive a next message from a message browser without removing them from a
persistent store of Queue Endpoints.
|
InboundMessage |
DirectMessageReceiver.receiveMessage()
Receive the next message.
|
InboundMessage |
PersistentMessageReceiver.receiveMessage(long timeOut)
Temporarily blocking request to receive a next message;
|
InboundMessage |
MessageQueueBrowser.receiveMessage(long timeOut)
Blocking request to receive a next message from a message browser without removing them from a
persistent store of Queue Endpoints.
|
InboundMessage |
DirectMessageReceiver.receiveMessage(long timeOut)
Receive the next message.
|
InboundMessage |
PersistentMessageReceiver.receiveOrElse(MessageReceiver.InboundMessageSupplier supplierOfAlternativeResponse)
Request to receive a next message, when no message available, given supplier is used to
generate a response, this method is nonblocking.
|
InboundMessage |
MessageQueueBrowser.receiveOrElse(MessageReceiver.InboundMessageSupplier supplierOfAlternativeResponse)
Request to receive a next message from a message browser without removing them from a
persistent store of Queue Endpoints.
|
InboundMessage |
DirectMessageReceiver.receiveOrElse(MessageReceiver.InboundMessageSupplier supplierOfAlternativeResponse)
Request to receive a next message, when no message available, the specified supplier is used to
generate a response.
|
Modifier and Type | Method and Description |
---|---|
void |
AcknowledgementSupport.ack(InboundMessage message)
Acknowledges the inbound message.
|
void |
InboundMessage.IncompatibleMessageHandler.onIncompatibleMessage(InboundMessage poisonMessage,
Converter.BytesToObject usedConverter,
Class<?> targetType,
PubSubPlusClientException.IncompatibleMessageException t)
The callback that executes when incompatible messages are received.
|
void |
MessageReceiver.MessageHandler.onMessage(InboundMessage message)
The callback for processing inbound messages.
|
void |
RequestReplyMessageReceiver.RequestMessageHandler.onMessage(InboundMessage message,
RequestReplyMessageReceiver.Replier replier)
The callback to handle a request message and to publish a response.
|
void |
MessageQueueBrowser.remove(InboundMessage message)
Request to remove a message from the PubSubPlus broker's Queue Endpoint.
|
void |
AcknowledgementSupport.settle(InboundMessage message,
MessageAcknowledgementConfiguration.Outcome settlementOutcome)
Settles a message in a requested way.
|
Copyright 2019-2024 Solace Corporation. All rights reserved.