Produce

Publish messages to a Solace Broker.

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

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

from *stringarrayobject

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 *string

The Solace hostname to connect with.

topicDestination *string

The topic destination to publish messages.

awaitAcknowledgementTimeout string

Default PT1M

Format duration

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

deliveryMode string

Default PERSISTENT

Possible Values

DIRECTPERSISTENT

The delivery mode to be used for publishing messages messages.

messageProperties object

SubType string

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 string

Default STRING

Possible Values

STRINGBINARYIONJSON

The Serializer to be used for serializing messages.

messageSerializerProperties object

Default {}

The config properties to be passed to the Serializer.

Configs in key/value pairs.

password string

The Solace password.

properties object

SubType string

Default {}

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

username string

The Solace username.

vpn string

Default default

The Solace VPN to connect with.

​Produce

Produce