From 9ea33517ebe30acce2e2ce7a41cd32ea168d3e85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A9r=C3=A9my=20Levilain?= Date: Tue, 2 Dec 2025 14:53:04 +0100 Subject: [PATCH] fix(amqp): bind logLevelOnInvalidMessage config to environment --- src/services/amqp.test.ts | 2 +- src/services/broker.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/services/amqp.test.ts b/src/services/amqp.test.ts index 3fcb640..04e265b 100644 --- a/src/services/amqp.test.ts +++ b/src/services/amqp.test.ts @@ -611,7 +611,7 @@ describe('services/amqp', () => { amqp.on('topic', (m) => (message = m)); - amqp.config.logLeverOnInvalidMessage = 'debug'; + amqp.config.logLevelOnInvalidMessage = 'debug'; jest.spyOn(amqp.telemetry.logger, 'error'); await amqp.subscribe('topic', { type: 'number' }); diff --git a/src/services/broker.ts b/src/services/broker.ts index 4092dfa..cd22435 100644 --- a/src/services/broker.ts +++ b/src/services/broker.ts @@ -89,7 +89,7 @@ export default class BrokerClient extends EventEmitter { }); /* @ts-ignore */ - this.telemetry?.logger[this.config.logLeverOnInvalidMessage ?? 'error']( + this.telemetry?.logger[this.config.logLevelOnInvalidMessage ?? 'error']( '[services#broker] Message is invalid', { err, -- GitLab