Solace Produce
CertifiedPublish messages to Solace topics
Solace Produce
Publish messages to Solace topics
Publishes one or more messages to a Solace Broker topic using the chosen serializer. Defaults to persistent delivery with a 1 minute acknowledgement wait; DIRECT skips acknowledgements.
type: io.kestra.plugin.solace.ProduceExamples
Publish a file as messages into a Solace Broker.
id: send_messages_to_solace_queue
namespace: company.team
inputs:
- id: file
type: FILE
description: a CSV file with columns id, username, tweet, and timestamp
tasks:
- id: read_csv_file
type: io.kestra.plugin.serdes.csv.CsvToIon
from: "{{ inputs.file }}"
- id: transform_row_to_json
type: io.kestra.plugin.graalvm.js.FileTransform
from: "{{ outputs.read_csv_file.uri }}"
script: |
var result = {
"payload": {
"username": row.username,
"tweet": row.tweet
},
"properties": {
"correlationId": "42"
}
};
row = result
- id: send_message_to_solace
type: io.kestra.plugin.solace.Produce
from: "{{ outputs.transform_row_to_json.uri }}"
topicDestination: test/tweets
host: localhost:55555
username: admin
password: "{{ secret('SOLACE_PASSWORD') }}"
vpn: default
messageSerializer: "JSON"
Properties
from *object
Message content
Internal storage URI (kestra://), a map, or a list of maps to publish.
host *string
Solace host
Broker hostname and port, for example localhost: 55555.
topicDestination *string
Topic destination
Rendered topic string for all outgoing messages.
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
{}1150awaitAcknowledgementTimeout string
PT1MAcknowledgement timeout
Max wait when deliveryMode is PERSISTENT. Defaults to 1 minute.
deliveryMode string
PERSISTENTDIRECTPERSISTENTDelivery mode
DIRECT sends immediately; PERSISTENT waits for broker acknowledgement.
messageProperties object
{}Message properties
Optional properties applied to every message. Keys must be String and values String; supports Solace message properties.
messageSerializer string
STRINGSTRINGBINARYIONJSONMessage serializer
Serde used to encode payloads. Defaults to STRING.
messageSerializerProperties object
{}Serializer properties
Key/value configs passed to the serializer.
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
Total number of messages published by the task
Metrics
messages counter
Number of messages
