Solace Trigger

Solace Trigger
Certified
Trigger flow from Solace queue

Polls a Solace queue and starts one execution per batch of received messages. Defaults: 60s interval, up to 100 messages or 10s per poll; respects the configured deserializer and selector.

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

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: "{{ secret('SOLACE_PASSWORD') }}"
    vpn: default
    messageDeserializer: JSON
    queueName: test_queue
    queueType: DURABLE_EXCLUSIVE

Properties

host *string

Solace host

Broker hostname and port, for example localhost: 55555.

queueName *string

Queue name

Queue to consume from.

queueType *string

Possible Values

DURABLE_EXCLUSIVEDURABLE_NON_EXCLUSIVENON_DURABLE_EXCLUSIVE

Queue type

Durability and access mode for the queue.

allowConcurrent boolean

Defaultfalse

Specifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.

interval string

DefaultPT1M

Formatduration

Polling interval

How often to poll Solace. Defaults to 60 seconds.

maxDuration string

DefaultPT10S

Maximum duration

Max poll duration before returning. Defaults to 10 seconds.

maxMessages integerstring

Default100

Maximum messages

Max messages per poll before returning. Defaults to 100.

messageDeserializer string

DefaultSTRING

Possible Values

STRINGBINARYIONJSON

Message deserializer

Serde used to decode payloads. Defaults to STRING.

messageDeserializerProperties object

Default{}

Deserializer properties

Key/value configs passed to the deserializer.

messageSelector string

Message selector

Solace selector expression to filter messages on headers/properties.

password string

Solace password

properties object

Default{}

Connection properties

Additional broker connection properties in key/value pairs.

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

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

username string

Solace username

vpn string

Defaultdefault

Solace VPN

VPN name to connect to. Defaults to default.

when string

Defaulttrue

A condition that determines whether the trigger should run.

A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.

Outputs

messagesCount integer

Messages consumed

Total number of messages received in this run.

uri string

Formaturi

Messages file URI

Internal storage URI (kestra://) containing the serialized messages.