Home / Connectors / RabbitMQ Receive Task Connector

RabbitMQ Receive Task Connector

Receive a message from RabbitMQ

inbound-intermediate

Required inputs

KeyLabelType
authentication.uri URI string
authentication.userName Username string
authentication.password Password secret
routing.virtualHost Virtual host string
routing.hostName Host name string
routing.port Port string
queueName Queue name string
correlationKeyProcess Correlation key (process) FEEL expression
correlationKeyPayload Correlation key (payload) FEEL expression
deduplicationId Deduplication ID string

Optional inputs

KeyLabelType
authentication.authType Connection type string
consumerTag Consumer tag string
arguments Arguments FEEL expression
exclusive Exclusive consumer string
activationCondition Activation condition FEEL expression
consumeUnmatchedEvents Consume unmatched events string
messageIdExpression Message ID expression FEEL expression
messageTtl Message TTL FEEL expression
deduplicationModeManualFlag Manual mode string
resultVariable Result variable string
resultExpression Result expression FEEL expression

Apply this connector with @bpmnkit/connectors

import { applyConnectorTemplate } from "@bpmnkit/connectors" const result = applyConnectorTemplate("io.camunda.connectors.inbound.RabbitMQ.Receive.v1", { "authentication.uri": "...", "authentication.userName": "...", "authentication.password": "<your password>", "routing.virtualHost": "...", "routing.hostName": "...", "routing.port": "...", "queueName": "...", "correlationKeyProcess": "= ...", "correlationKeyPayload": "= ...", "deduplicationId": "...", "authentication.authType": "uri", "consumerTag": "...", })