Package | Description |
---|---|
com.solace.messaging.publisher |
A package that contains interfaces and classes to handle publishing messages.
|
com.solace.messaging.resources |
A package of interfaces to work with PubSub+ topics, queues, share names, and information about
received 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 |
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.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 |
---|---|
static Topic |
Topic.of(String expression)
A factory method to create instances of
Topic for the specified topic expression. |
static Topic |
Topic.of(String expression,
boolean temporary)
A factory method to create instances of
Topic for the specified topic expression,
creator can indicate if it is temporary or not. |
Copyright 2019-2024 Solace Corporation. All rights reserved.