Solace Consume

Solace Consume

Certified

Consume messages from Solace queue

Pulls messages from a Solace queue, deserializes them, and writes them to internal storage. Defaults to STRING deserializer, up to 100 messages or 10 seconds per poll; returns the storage URI and message count.

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

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: "{{ secret('SOLACE_PASSWORD') }}"
    vpn: default
    messageDeserializer: JSON
    queueName: test_queue
    queueType: DURABLE_EXCLUSIVE
Properties

Solace host

Broker hostname and port, for example localhost: 55555.

Queue name

Solace queue to consume from.

Possible Values
DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVE

Queue type

Durability and access mode for the queue.

DefaultPT10S

Maximum duration

Max poll duration. Defaults to 10 seconds.

Default100

Maximum messages

Upper bound of messages per poll. Defaults to 100.

DefaultSTRING
Possible Values
STRINGBINARYIONJSON

Message deserializer

Serde used to decode messages. Defaults to STRING.

Default{}

Deserializer properties

Key/value configs passed to the deserializer.

Message selector

Solace selector expression to filter messages on headers/properties.

Solace password

Reference (ref) of the pluginDefaults to apply to this task.

Default{}

Connection properties

Additional broker connection properties in key/value pairs.

Solace username

Defaultdefault

Solace VPN

VPN name to connect to. Defaults to default when not overridden.

Messages consumed

Total number of messages received in this run.

Formaturi

Messages file URI

Internal storage URI (kestra://) containing the serialized messages.

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints