RabbitMQ Receive Task Connector
Receive a message from RabbitMQ
Required inputs
| Key | Label | Type |
|---|---|---|
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
| Key | Label | Type |
|---|---|---|
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": "...",
})