diff --git a/src/services/amqp.test.ts b/src/services/amqp.test.ts index 3fcb6405d1cfe2e7d739c8ef0ab79bfee9afcaa7..04e265babb6e07edb03a6706d6a1a641de0c8889 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 4092dfafde47deb868e9652dc885029923aa4389..cd224357bfc5833e6669403d06a3c7438df7f408 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,