RabbitMQ Message Start Event Connector
Receive a message from RabbitMQ
Required inputs
| Key | Label | Type |
|---|---|---|
authentication.uri | URI | string |
authentication.userName | Username | string |
authentication.password | Password | secret |
routing.hostName | Host name | string |
routing.virtualHost | Virtual host | string |
routing.port | Port | string |
queueName | Queue name | FEEL expression |
| Correlation key (process) | FEEL expression |
correlationKeyExpression | Correlation key (payload) | FEEL expression |
Optional inputs
| Key | Label | Type |
|---|---|---|
connectionType | Connection type | string |
consumerTag | Consumer tag | FEEL expression |
arguments | Arguments | FEEL expression |
exclusive | Exclusive consumer | string |
messageIdExpression | Message ID expression | FEEL expression |
activationCondition | Activation condition | FEEL expression |
correlationRequired | Correlation required | 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.MessageStart.v1", {
"authentication.uri": "...",
"authentication.userName": "...",
"authentication.password": "<your password>",
"routing.hostName": "...",
"routing.virtualHost": "...",
"routing.port": "...",
"queueName": "= ...",
"": "= ...",
"correlationKeyExpression": "= ...",
"connectionType": "uri",
"consumerTag": "= ...",
})