consume
Consume messages from a Solace broker.
Consume messages from a Solace broker.
Consume messages from a Solace broker.
type: "io.kestra.plugin.solace.consume"Examples
Consume messages from a Solace queue.
id: consume_message_from_solace_queue
namespace: company.team
tasks:
- id: consume_from_solace
type: io.kestra.plugin.solace.Consume
host: localhost:55555
username: admin
password: admin
vpn: default
messageDeserializer: JSON
queueName: test_queue
queueType: DURABLE_EXCLUSIVE
Properties
host*Requiredstring
The Solace hostname to connect with.
queueName*Requiredstring
The name of the solace queue to consume from.
queueType*Requiredstring
DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVEThe type of the queue to be consumed.
maxDurationstring
PT10SdurationThe maximum time to wait for receiving a number of messages up to maxMessages.
maxMessagesintegerstring
100The maximum number of messages to be received per poll.
messageDeserializerstring
STRINGSTRINGBINARYIONJSONThe Deserializer to be used for deserializing messages.
messageDeserializerPropertiesobject
{}The config properties to be passed to the Deserializer.
Configs in key/value pairs.
messageSelectorstring
The message selector to be used for receiving messages.
Enables support for message selection based on message header parameter and message properties values.
passwordstring
The Solace password.
propertiesobject
{}The Solace properties to be used for connecting to the broker.
usernamestring
The Solace username.
vpnstring
defaultThe Solace VPN to connect with.
Outputs
messagesCountinteger
Number of messages consumed from the Solace broker.
uristring
uriURI of a Kestra's internal storage file containing the messages.
