Consume

yaml
type: "io.kestra.plugin.jms.Consume"

Examples

yaml
id: jms_consume
namespace: company.team

tasks:
  - id: consume_from_queue
    type: io.kestra.plugin.jms.Consume
    connectionFactoryConfig:
      type: DIRECT
      providerJarPaths: kestra:///jms/activemq-client.jar
      connectionFactoryClass: org.apache.activemq.ActiveMQConnectionFactory
      username: admin
      password: "{{ secret('AMQ_PASSWORD') }}"
    destination:
      name: my-queue
      destinationType: QUEUE
    maxMessages: 100
    maxWaitTimeout: 5000

Properties

destination*

Definitions

io.kestra.plugin.jms.JMSDestination

destinationName*string

destinationTypestring

DefaultQUEUE

Possible Values

QUEUETOPIC

connectionFactoryConfig

Definitions

io.kestra.plugin.jms.configuration.ConnectionFactoryConfig-Direct

connectionFactoryClass*string

connectionPropertiesobject

passwordstring

providerJarPathsarray

SubTypestring

useFilteredClassLoaderbooleanstring

Defaultfalse

usernamestring

io.kestra.plugin.jms.configuration.ConnectionFactoryConfig-Jndi

jndiConnectionFactoryName*string

jndiInitialContextFactory*string

jndiProviderUrl*string

connectionPropertiesobject

jndiCredentialsstring

jndiPrincipalstring

passwordstring

providerJarPathsarray

SubTypestring

useFilteredClassLoaderbooleanstring

Defaultfalse

usernamestring

maxMessagesintegerstring

Default1

maxWaitTimeoutintegerstring

Default0

messageSelectorstring

serdeTypestring

DefaultSTRING

Possible Values

STRINGJSONBYTES

Outputs

countinteger

uristring

Formaturi

Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Database

SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

Consume

More Plugins in this Category

Core Plugins and tasks

PostgreSQL

SurrealDB

1.1.2