diff --git a/packages/nodes-base/nodes/RabbitMQ/GenericFunctions.ts b/packages/nodes-base/nodes/RabbitMQ/GenericFunctions.ts index cca2cd9e6f..b0385e393c 100644 --- a/packages/nodes-base/nodes/RabbitMQ/GenericFunctions.ts +++ b/packages/nodes-base/nodes/RabbitMQ/GenericFunctions.ts @@ -22,6 +22,11 @@ export async function rabbitmqConnect( }, {} as IDataObject) as amqplib.Options.Connect; const optsData: IDataObject = {}; + + optsData.clientProperties = { + connection_name: "n8n" // should customize this + }; + if (credentials.ssl) { credentialData.protocol = 'amqps';