Package | Description |
---|---|
com.solace.messaging.receiver |
A package that contains interfaces and classes to handle receiving messages.
|
Modifier and Type | Method and Description |
---|---|
static MessageReceiver.InboundMessageSupplier |
MessageReceiver.InboundMessageSupplier.byteMessageSupplier(byte[] payload)
Creates a message supplier with a given payload.
|
static MessageReceiver.InboundMessageSupplier |
MessageReceiver.InboundMessageSupplier.nullMessageSupplier()
Creates a message supplier that creates
null messages. |
static MessageReceiver.InboundMessageSupplier |
MessageReceiver.InboundMessageSupplier.stringMessageSupplier(String payload)
Creates a message supplier with a given payload.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright 2019-2024 Solace Corporation. All rights reserved.