Solace Produce

Solace Produce

Certified

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.

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

Publish a file as messages into a Solace Broker.

yaml
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

Message content

Internal storage URI (kestra://), a map, or a list of maps to publish.

Solace host

Broker hostname and port, for example localhost: 55555.

Topic destination

Rendered topic string for all outgoing messages.

DefaultPT1M

Acknowledgement timeout

Max wait when deliveryMode is PERSISTENT. Defaults to 1 minute.

DefaultPERSISTENT
Possible Values
DIRECTPERSISTENT

Delivery mode

DIRECT sends immediately; PERSISTENT waits for broker acknowledgement.

Default{}

Message properties

Optional properties applied to every message. Keys must be String and values String; supports Solace message properties.

DefaultSTRING
Possible Values
STRINGBINARYIONJSON

Message serializer

Serde used to encode payloads. Defaults to STRING.

Default{}

Serializer properties

Key/value configs passed to the serializer.

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.

Total number of messages published by the task

Number of 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