Consume
yaml
type: "io.kestra.plugin.solace.consume"
Examples
yaml
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
queueName *Requiredstring
queueType *Requiredstring
Possible Values
DURABLE_EXCLUSIVE
DURABLE_NON_EXCLUSIVE
NON_DURABLE_EXCLUSIVE
maxDuration string
Default
PT10S
Format
duration
maxMessages integerstring
Default
100
messageDeserializer string
Default
STRING
Possible Values
STRING
BINARY
ION
JSON
messageDeserializerProperties object
Default
{}
messageSelector string
password string
properties object
SubType string
Default
{}
username string
vpn string
Default
default
Outputs
messagesCount integer
uri string
Format
uri