feat: improve distributed message bus + fix readme

Author: Sebastian-Iwanczyszyn

README.md

@@ -159,7 +159,7 @@ export class AppController {
     - This implementation illustrates an entry point triggered via an HTTP request, showcasing how simple it is to connect the messaging system to a web interface.
 
 ### ⚠️ Warning!
-🚨 Important Notice: You can return responses from handlers, but currently, it only works with the `InMemoryChannel`. This behavior may not function as expected if multiple handlers are processing a single message.
+🚨 Important Notice: You can **return responses from handlers**, but currently, it only works with the `InMemoryChannel`. This behavior may not function as expected if multiple handlers are processing a single message.
 
 🛠️ Please ensure you're using a compatible setup when working with multiple handlers, as this could result in unexpected behavior.
 
@@ -453,6 +453,3 @@ export class YourMessageOptions implements MessageOptions {
 Classes with `Injectable()` decorator must be defined as providers in somewhere in application.
 
 ---
-
-### Future features
-* INBOX & OUTBOX Pattern

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjstools/messaging",
-  "version": "2.17.1",
+  "version": "2.18.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",
@@ -21,13 +21,15 @@
     "package.json"
   ],
   "keywords": [
-    "nestjs-tools",
+    "nestjstools",
     "nestjs",
     "distributed",
     "messaging",
     "nestjs-messaging",
     "message-bus",
     "service-bus",
+    "nestjs-service-bus",
+    "nestjs-message-bus",
     "microservices"
   ],
   "scripts": {
@@ -52,7 +54,7 @@
   "peerDependencies": {
     "@nestjs/common": "^10.x||^11.x",
     "@nestjs/core": "^10.x||^11.x",
-    "reflect-metadata": "^0.2.0",
+    "reflect-metadata": "^0.2.x",
     "rxjs": "^7.x"
   },
   "devDependencies": {

src/bus/distributed-message.bus.ts

@@ -10,7 +10,7 @@ import { NormalizerRegistry } from '../normalizer/normalizer.registry';
 export class DistributedMessageBus implements IMessageBus {
   constructor(private messageBusCollection: MessageBusCollection, private normalizerRegistry: NormalizerRegistry) {}
 
-  async dispatch(message: RoutingMessage): Promise<MessageResponse | void> {
+  async dispatch(message: RoutingMessage): Promise<MessageResponse> {
     if (!(message instanceof RoutingMessage)) {
       throw new Error(`Message must be instance of ${RoutingMessage.name}`);
     }

src/message/message-response.ts

@@ -9,6 +9,10 @@ export class MessageResponse {
     return this.responses[0];
   }
 
+  isEmpty(): boolean {
+    return 0 === this.responses.length;
+  }
+
   getAll(): object[] {
     return this.responses;
   }