fix: improve logger for async consumer (#28)

* Fix error not propagated in Distributed Consumer (#27)

* fix: improve and fix logger for async consumer

---------

Co-authored-by: Julien lafont <155448870+julienlafont-shine@users.noreply.github.com>

Author: Sebastian-Iwanczyszyn

src/channel/channel.ts

@@ -3,5 +3,5 @@ import { ChannelConfig } from '../config';
 export class Channel<T extends ChannelConfig> {
   constructor(public readonly config: T) {}
 
-  async onChannelDestroy(): Promise<void> {};
+  async onChannelDestroy(): Promise<void> {}
 }

src/consumer/distributed.consumer.ts

@@ -104,7 +104,7 @@ export class DistributedConsumer {
               Log.create(
                 `Some error occurred in channel [${channel.config.name}]`,
                 {
-                  error: e,
+                  error: e instanceof Error ? e.message : String(e),
                   message: JSON.stringify(consumerMessage.message),
                   routingKey: consumerMessage.routingKey,
                 },

src/messaging.module.ts

@@ -3,7 +3,9 @@ import {
   FactoryProvider,
   Logger as NestCommonLogger,
   Module,
-  OnApplicationBootstrap, OnApplicationShutdown, OnModuleDestroy,
+  OnApplicationBootstrap,
+  OnApplicationShutdown,
+  OnModuleDestroy,
   Provider,
 } from '@nestjs/common';
 import {
@@ -44,7 +46,9 @@ import { ExceptionListenerRegistry } from './exception-listener/exception-listen
 import { ExceptionListenerHandler } from './exception-listener/exception-listener-handler';
 
 @Module({})
-export class MessagingModule implements OnApplicationBootstrap, OnModuleDestroy {
+export class MessagingModule
+  implements OnApplicationBootstrap, OnModuleDestroy
+{
   static forRoot(options: MessagingModuleOptions): DynamicModule {
     const channels = options.channels ?? [];
 
@@ -240,7 +244,9 @@ export class MessagingModule implements OnApplicationBootstrap, OnModuleDestroy
   }
 
   async onModuleDestroy(): Promise<any> {
-    const channels: Channel<ChannelConfig>[] = this.moduleRef.get(Service.CHANNELS);
+    const channels: Channel<ChannelConfig>[] = this.moduleRef.get(
+      Service.CHANNELS,
+    );
 
     for (const channel of channels) {
       await channel.onChannelDestroy();