feat: lift exceptions

Author: Sebastian-Iwanczyszyn

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjstools/messaging",
-  "version": "3.0.2",
+  "version": "3.1.0",
   "description": "Simplifies asynchronous and synchronous message handling with support for buses, handlers, channels, and consumers. Build scalable, decoupled applications with ease and reliability.",
   "author": "Sebastian Iwanczyszyn",
   "license": "MIT",
@@ -43,8 +43,6 @@
     "lint": "node_modules/.bin/eslint \"{src,apps,libs,test}/**/*.ts\" --fix",
     "test": "npm run test:e2e && npm run test:unit",
     "test:watch": "node_modules/.bin/jest --watch",
-    "test:unit:watch": "node_modules/.bin/jest --watch --config ./test/jest-unit.json",
-    "test:cov": "node_modules/.bin/jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
     "test:e2e": "node_modules/.bin/jest --config ./test/jest-e2e.json",
     "test:unit": "node_modules/.bin/jest --config ./test/jest-unit.json"

src/messaging.module.ts

@@ -240,7 +240,7 @@ export class MessagingModule
     private readonly discoveryService: DiscoveryService,
   ) {}
 
-  onApplicationBootstrap(): any {
+  onApplicationBootstrap(): void {
     registerHandlers(this.moduleRef, this.discoveryService);
     registerMiddlewares(this.moduleRef, this.discoveryService);
     registerMessageNormalizers(this.moduleRef, this.discoveryService);

src/normalizer/object-forward-message.normalizer.ts

@@ -1,5 +1,6 @@
 import { MessageNormalizer } from './message-normalizer';
 import { MessagingNormalizer } from '../dependency-injection/decorator';
+import { MessagingException } from '../exception/messaging.exception';
 
 @MessagingNormalizer()
 export class ObjectForwardMessageNormalizer implements MessageNormalizer {
@@ -9,7 +10,7 @@ export class ObjectForwardMessageNormalizer implements MessageNormalizer {
 
   async denormalize(message: string | object, type: string): Promise<object> {
     if (typeof message !== 'object') {
-      throw new Error('Unable to denormalize object');
+      throw new MessagingException('Unable to denormalize object');
     }
 
     return message;