From 3c48b06884411ec4ae1d0d4421562d28db85e204 Mon Sep 17 00:00:00 2001 From: Jan Oberhauser Date: Thu, 8 Apr 2021 23:34:10 +0200 Subject: [PATCH] :bug: Fix issue that RabbitMQ Trigger node did reuse same item --- .../nodes-base/nodes/RabbitMQ/RabbitMQTrigger.node.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/nodes-base/nodes/RabbitMQ/RabbitMQTrigger.node.ts b/packages/nodes-base/nodes/RabbitMQ/RabbitMQTrigger.node.ts index 446bd82352..f39cacf080 100644 --- a/packages/nodes-base/nodes/RabbitMQ/RabbitMQTrigger.node.ts +++ b/packages/nodes-base/nodes/RabbitMQ/RabbitMQTrigger.node.ts @@ -107,15 +107,15 @@ export class RabbitMQTrigger implements INodeType { const self = this; - const item: INodeExecutionData = { - json: {}, - }; - const startConsumer = async () => { await channel.consume(queue, async (message: IDataObject) => { if (message !== null) { let content: IDataObject | string = message!.content!.toString(); + const item: INodeExecutionData = { + json: {}, + }; + if (options.contentIsBinary === true) { item.binary = { data: await this.helpers.prepareBinaryData(message.content),