Produce

yaml

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

Publish messages to a Solace Broker.

Examples

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.scripts.nashorn.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: admin
    vpn: default
    messageSerializer: "JSON"

Properties

`awaitAcknowledgementTimeout`

Type: string
Dynamic: ❌
Required: ✔️
Default: 60.000000000
Format: duration

The maximum time to wait for the message acknowledgement (in milliseconds) when configuring deliveryMode to PERSISTENT.

`from`

Type:
- string
- array
- object
Dynamic: ✔️
Required: ✔️

The content of the message to be published to Solace

Can be an internal storage URI, a map (i.e. a list of key-value pairs) or a list of maps. The following keys are supported: payload, properties.

`host`

Type: string
Dynamic: ✔️
Required: ✔️

The Solace hostname to connect with.

`topicDestination`

Type: string
Dynamic: ✔️
Required: ✔️

The topic destination to publish messages.

`vpn`

Type: string
Dynamic: ✔️
Required: ✔️
Default: default

The Solace VPN to connect with.

`deliveryMode`

Type: string
Dynamic: ❌
Required: ❌
Default: PERSISTENT
Possible Values:
- DIRECT
- PERSISTENT

The delivery mode to be used for publishing messages messages.

`messageProperties`

Type: object
SubType: string
Dynamic: ❌
Required: ❌
Default: {}

Additional properties to customize all messages to be published.

Additional properties must be provided with Key of type String and Value of type String. Each key can be customer provided, or it can be a Solace message properties.