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 |
---|---|
OutboundMessage |
OutboundMessageBuilder.build(byte[] payload)
Creates an outbound message using the configuration provided by
this instance of a
message builder and the byte-array payload. |
OutboundMessage |
OutboundMessageBuilder.build(byte[] payload,
Properties extendedMessageProperties)
Creates an outbound message using the configuration provided by
this instance of a
message builder and byte-array payload. |
OutboundMessage |
OutboundMessageBuilder.build(String payload)
Creates an outbound message using configuration provided by
this instance of a message
builder and string payload. |
OutboundMessage |
OutboundMessageBuilder.build(String payload,
Properties extendedMessageProperties)
Creates an outbound message using configuration provided by
this instance of a message
builder and string payload. |
<T extends Serializable> |
OutboundMessageBuilder.build(T payload,
Converter.ObjectToBytes<T> converter)
Creates an outbound message using configuration provided by
this instance of a message
builder and some serializable payload, converter |
<T extends Serializable> |
OutboundMessageBuilder.build(T payload,
Converter.ObjectToBytes<T> converter,
Properties extendedMessageProperties)
Creates an outbound message using configuration provided by
this instance of a message
builder and some serializable payload, converter and extended properties |
OutboundMessage |
PersistentMessagePublisher.PublishReceipt.getMessage()
Retrieves message associated with a Receipt.
|
OutboundMessage |
DirectMessagePublisher.FailedPublishEvent.getMessage()
Retrieves a message that's associated with a given event.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestReplyMessagePublisher.publish(OutboundMessage requestMessage,
Properties additionalMessageProperties,
RequestReplyMessagePublisher.ReplyMessageHandler replyMessageHandler,
Object userContext,
Topic requestDestination,
long replyTimeout)
Sends a request for reply message; nonblocking.
|
void |
RequestReplyMessagePublisher.publish(OutboundMessage requestMessage,
RequestReplyMessagePublisher.ReplyMessageHandler replyMessageHandler,
Object userContext,
Topic requestDestination,
long replyTimeout)
Sends a request for reply message; nonblocking.
|
void |
RequestReplyMessagePublisher.publish(OutboundMessage requestMessage,
RequestReplyMessagePublisher.ReplyMessageHandler replyMessageHandler,
Topic requestDestination,
long replyTimeout)
Sends a request for reply message; nonblocking.
|
void |
PersistentMessagePublisher.publish(OutboundMessage message,
Topic destination)
Sends a persistent message; nonblocking
|
void |
DirectMessagePublisher.publish(OutboundMessage message,
Topic destination)
Sends an
OutboundMessage to the given destination, non blocking. |
void |
PersistentMessagePublisher.publish(OutboundMessage message,
Topic destination,
Object userContext)
Sends a persistent message to the given destination, non blocking
|
void |
PersistentMessagePublisher.publish(OutboundMessage message,
Topic destination,
Object userContext,
Properties additionalMessageProperties)
Sends a persistent message to the given destination, non-blocking
|
void |
DirectMessagePublisher.publish(OutboundMessage message,
Topic destination,
Properties additionalMessageProperties)
Sends
OutboundMessage to the given destination, extendedMessageProperties can
be included into the message, non blocking. |
void |
PersistentMessagePublisher.publishAwaitAcknowledgement(OutboundMessage message,
Topic destination,
long timeout)
Sends a persistent message, blocking until delivery acknowledgement is received or timeout
occurs.
|
void |
PersistentMessagePublisher.publishAwaitAcknowledgement(OutboundMessage message,
Topic destination,
long timeout,
Properties additionalMessageProperties)
Sends a persistent message, blocking until delivery acknowledgement is received or timeout
occurs
|
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 |
---|---|
OutboundMessage |
RequestReplyMessageReceiver.FailedReplyEvent.getReplyMessage()
Retrieves a reply message that's associated with a given event.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestReplyMessageReceiver.Replier.reply(OutboundMessage responseMessage)
Publish a reply or response message.
|
void |
RequestReplyMessageReceiver.Replier.reply(OutboundMessage responseMessage,
Properties additionalMessageProperties)
Publish a reply or response message.
|
Copyright 2019-2024 Solace Corporation. All rights reserved.