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 |
---|---|
void |
PersistentMessagePublisher.publish(byte[] message,
Topic destination)
Sends a persistent byte-array message to the given destination using defaults.
|
void |
DirectMessagePublisher.publish(byte[] message,
Topic destination)
Sends a byte-array message to the given destination using defaults This method is
non-blocking.
|
void |
PersistentMessagePublisher.publish(byte[] message,
Topic destination,
Object userContext)
Sends a persistent byte array message to the given destination using defaults.
|
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.publish(String message,
Topic destination)
Sends a UTF-8 encoded persistent text message as a payload to the given destination using
defaults.
|
void |
DirectMessagePublisher.publish(String message,
Topic destination)
Sends a UTF-8 encoded-text message (payload) to the specified destination using defaults This
method is non-blocking.
|
void |
PersistentMessagePublisher.publish(String message,
Topic destination,
Object userContext)
Sends a UTF-8 encoded persistent text message as the payload to the given destination using
defaults.
|
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 |
---|---|
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.