Produce 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.

messageSerializer

  • Type: string
  • Dynamic:
  • Required:
  • Default: STRING
  • Possible Values:
    • STRING
    • BINARY
    • ION
    • JSON

The Serializer to be used for serializing messages.

messageSerializerProperties

  • Type: object
  • Dynamic:
  • Required:
  • Default: {}

The config properties to be passed to the Serializer.

Configs in key/value pairs.

password

  • Type: string
  • Dynamic: ✔️
  • Required:

The Solace password.

properties

  • Type: object
  • SubType: string
  • Dynamic: ✔️
  • Required:
  • Default: {}

The Solace properties to be used for connecting to the broker.

username

  • Type: string
  • Dynamic: ✔️
  • Required:

The Solace username.

Outputs

Definitions

Was this page helpful?