Trigger Trigger

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

Trigger flow based on messages received from a Solace broker.

Examples

Trigger flow based on messages received from a Solace broker.

yaml
id: trigger_from_solace_queue
namespace: company.team

tasks:
  - id: hello
    type: io.kestra.plugin.core.log.Log
    message: Hello there! I received {{ trigger.messagesCount }} from Solace!

triggers:
  - id: read_from_solace
    type: io.kestra.plugin.solace.Trigger
    interval: PT30S
    host: localhost:55555
    username: admin
    password: admin
    vpn: default
    messageDeserializer: JSON
    queueName: test_queue
    queueType: DURABLE_EXCLUSIVE

Properties

host

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

The Solace hostname to connect with.

messageDeserializer

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

The Deserializer to be used for deserializing messages.

queueName

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

The name of the solace queue to consume from.

queueType

  • Type: string
  • Dynamic:
  • Required: ✔️
  • Possible Values:
    • DURABLE_EXCLUSIVE
    • DURABLE_NON_EXCLUSIVE
    • NON_DURABLE_EXCLUSIVE

The type of the queue to be consumed.

vpn

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

The Solace VPN to connect with.

conditions

  • Type: array
  • SubType: Condition
  • Dynamic:
  • Required:

List of conditions in order to limit the flow trigger.

interval

  • Type: string
  • Dynamic:
  • Required:
  • Default: 60.000000000
  • Format: duration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.

maxDuration

  • Type: string
  • Dynamic:
  • Required:
  • Default: 10.000000000
  • Format: duration

The maximum time to wait for receiving a number of messages up to maxMessages.

maxMessages

  • Type: integer
  • Dynamic:
  • Required:
  • Default: 100

The maximum number of messages to be received per poll.

messageDeserializerProperties

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

The config properties to be passed to the Deserializer.

Configs in key/value pairs.

messageSelector

  • Type: string
  • Dynamic:
  • Required:

The message selector to be used for receiving messages.

Enables support for message selection based on message header parameter and message properties values.

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.

stopAfter

  • Type: array
  • SubType: string
  • Dynamic:
  • Required:

List of execution states after which a trigger should be stopped (a.k.a. disabled).

username

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

The Solace username.

Outputs

messagesCount

  • Type: integer
  • Required:

Number of messages consumed from the Solace broker.

uri

  • Type: string
  • Required:
  • Format: uri

URI of a Kestra's internal storage file containing the messages.

Definitions

Was this page helpful?