Consume

Consume messages from a Solace broker.

yaml
type: "io.kestra.plugin.solace.Consume"

Examples

Consume messages from a Solace queue.

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 *string

The Solace hostname to connect with.

queueName *string

The name of the solace queue to consume from.

queueType *string

Possible Values

DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVE

The type of the queue to be consumed.

maxDuration string

Default PT10S

Format duration

The maximum time to wait for receiving a number of messages up to maxMessages.

maxMessages integerstring

Default 100

The maximum number of messages to be received per poll.

messageDeserializer string

Default STRING

Possible Values

STRINGBINARYIONJSON

The Deserializer to be used for deserializing messages.

messageDeserializerProperties object

Default {}

The config properties to be passed to the Deserializer.

Configs in key/value pairs.

messageSelector string

The message selector to be used for receiving messages.

Enables support for message selection based on message header parameter and message properties values.

password string

The Solace password.

properties object

SubType string

Default {}

The Solace properties to be used for connecting to the broker.

username string

The Solace username.

vpn string

Default default

The Solace VPN to connect with.

Outputs

messagesCount integer

Number of messages consumed from the Solace broker.

uri string

Format uri

URI of a Kestra's internal storage file containing the messages.

​Consume

Consume