Skip to content

Amqp Trigger

Node: amqpTrigger · Full type: n8n-nodes-base.amqpTrigger · Version: 1

Credentials

amqp (alias: @amqp)

CREDENTIAL @amqp = amqp "My Amqp Trigger"

Parameters

Parameter Type Default Details
sink string ""
clientname string ""
subscription string ""
options collection {} keys: containerId, jsonConvertByteArrayToString, jsonParseBody, pullMessagesNumber, onlyBody, parallelProcessing, ...

options children:

Parameter Type Default Details
containerId string ""
jsonConvertByteArrayToString boolean false
jsonParseBody boolean false
pullMessagesNumber number 100
onlyBody boolean false
parallelProcessing boolean true
reconnect boolean true
reconnectLimit number 50
sleepTime number 10

Example

NODE "amqpTrigger" @amqp AS "Amqp Trigger" {
  sink: "value",
  clientname: "value",
  subscription: "value"
}