Trigger

Trigger flow based on messages received from a Solace broker.

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

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

Dynamic YES

The Solace hostname to connect with.

Dynamic YES

The name of the solace queue to consume from.

Dynamic YES

Possible Values

DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVE

The type of the queue to be consumed.

Dynamic YES

Default default

The Solace VPN to connect with.

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic NO

Default 60

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.

Dynamic YES

Default PT10S

Format duration

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

Dynamic YES

Default 100

Dynamic YES

Default STRING

Possible Values

STRINGBINARYIONJSON

The Deserializer to be used for deserializing messages.

Dynamic YES

Default {}

The config properties to be passed to the Deserializer.

Configs in key/value pairs.

Dynamic YES

The message selector to be used for receiving messages.

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

Dynamic YES

The Solace password.

SubType string

Dynamic YES

Default {}

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

SubType string

Dynamic NO

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

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

Dynamic YES

The Solace username.

Number of messages consumed from the Solace broker.

Format uri

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

​Trigger

Trigger