Solace Consume
CertifiedConsume messages from Solace queue
Solace Consume
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.
type: io.kestra.plugin.solace.ConsumeExamples
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: "{{ secret('SOLACE_PASSWORD') }}"
vpn: default
messageDeserializer: JSON
queueName: test_queue
queueType: DURABLE_EXCLUSIVE
Properties
host *string
Solace host
Broker hostname and port, for example localhost: 55555.
queueName *string
Queue name
Solace queue to consume from.
queueType *string
DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVEQueue type
Durability and access mode for the queue.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150maxDuration string
PT10SMaximum duration
Max poll duration. Defaults to 10 seconds.
maxMessages integerstring
100Maximum messages
Upper bound of messages per poll. Defaults to 100.
messageDeserializer string
STRINGSTRINGBINARYIONJSONMessage deserializer
Serde used to decode messages. Defaults to STRING.
messageDeserializerProperties object
{}Deserializer properties
Key/value configs passed to the deserializer.
messageSelector string
Message selector
Solace selector expression to filter messages on headers/properties.
password string
Solace password
properties object
{}Connection properties
Additional broker connection properties in key/value pairs.
username string
Solace username
vpn string
defaultSolace VPN
VPN name to connect to. Defaults to default when not overridden.
Outputs
messagesCount integer
Messages consumed
Total number of messages received in this run.
uri string
uriMessages file URI
Internal storage URI (kestra://) containing the serialized messages.
