Amazon SQS Receive Task Connector
Receive messages from Amazon SQS.
Required inputs
| Key | Label | Type |
|---|---|---|
authentication.accessKey | Access key | secret |
authentication.secretKey | Secret key | secret |
configuration.region | Region | string |
queue.queue.url | Queue URL | string |
queue.queue.pollingWaitTime | Polling wait time | string |
correlationKeyProcess | Correlation key (process) | FEEL expression |
correlationKeyPayload | Correlation key (payload) | FEEL expression |
deduplicationId | Deduplication ID | string |
Optional inputs
| Key | Label | Type |
|---|---|---|
authentication.type | Authentication | string |
queue.queue.attributeNames | Attribute names | FEEL expression |
queue.queue.messageAttributeNames | Message attribute names | FEEL expression |
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.AWSSQS.receive.v1", {
"authentication.accessKey": "<your access key>",
"authentication.secretKey": "<your secret key>",
"configuration.region": "...",
"queue.queue.url": "...",
"queue.queue.pollingWaitTime": "20",
"correlationKeyProcess": "= ...",
"correlationKeyPayload": "= ...",
"deduplicationId": "...",
"authentication.type": "defaultCredentialsChain",
"queue.queue.attributeNames": "= ...",
})