@node-ts/bus-core - npm Package Compare versions

Comparing version 0.6.9 to 0.6.10

dist/service-bus/service-bus.d.ts

@@ -20,7 +20,7 @@ import { Bus, BusState } from './bus';
     private messageReadMiddlewares;
-    constructor(transport: Transport<{}>, logger: Logger, handlerRegistry: HandlerRegistry, messageHandlingContext: MessageAttributes, busHooks: BusHooks, busConfiguration: BusConfiguration, rawMessage: TransportMessage<unknown>);
+    constructor(transport: Transport<unknown>, logger: Logger, handlerRegistry: HandlerRegistry, messageHandlingContext: MessageAttributes, busHooks: BusHooks, busConfiguration: BusConfiguration, rawMessage: TransportMessage<unknown>);
     publish<TEvent extends Event>(event: TEvent, messageOptions?: MessageAttributes): Promise<void>;
     fail(): Promise<void>;
     send<TCommand extends Command>(command: TCommand, messageOptions?: MessageAttributes): Promise<void>;
-    messageReadMiddleware<MessageType>(messageReadMiddleware: Middleware<TransportMessage<MessageType>>): void;
+    messageReadMiddleware<TransportMessageType>(messageReadMiddleware: Middleware<TransportMessage<TransportMessageType>>): void;
     start(): Promise<void>;
@@ -27,0 +27,0 @@ stop(): Promise<void>;

package.json

 {
   "name": "@node-ts/bus-core",
-  "version": "0.6.9",
+  "version": "0.6.10",
   "description": "A service bus for message-based, distributed node applications",
@@ -50,3 +50,3 @@ "main": "./dist/index.js",
   ],
-  "gitHead": "02fb2fe28c190b1562f256ba5b34255336c6da25"
+  "gitHead": "8fe41d2fa97bd4147252685db6a0cef324eb7f22"
 }

src/service-bus/service-bus.ts

@@ -23,6 +23,6 @@ import { injectable, inject, optional } from 'inversify'
   private runningWorkerCount = 0
-  private messageReadMiddlewares: MiddlewareDispatcher<TransportMessage<MessageType>>
+  private messageReadMiddlewares: MiddlewareDispatcher<TransportMessage<unknown>>
 
   constructor (
-    @inject(BUS_SYMBOLS.Transport) private readonly transport: Transport<{}>,
+    @inject(BUS_SYMBOLS.Transport) private readonly transport: Transport<unknown>,
     @inject(LOGGER_SYMBOLS.Logger) private readonly logger: Logger,
@@ -36,3 +36,3 @@ @inject(BUS_SYMBOLS.HandlerRegistry) private readonly handlerRegistry: HandlerRegistry,
   ) {
-    this.messageReadMiddlewares = new MiddlewareDispatcher<TransportMessage<MessageType>>()
+    this.messageReadMiddlewares = new MiddlewareDispatcher<TransportMessage<unknown>>()
     // Register our message handling middleware
@@ -72,3 +72,3 @@ this.messageReadMiddlewares.useFinal(this.handleNextMessagePolled)
 
-  messageReadMiddleware<MessageType>(messageReadMiddleware: Middleware<TransportMessage<MessageType>>) {
+  messageReadMiddleware<TransportMessageType>(messageReadMiddleware: Middleware<TransportMessage<TransportMessageType>>) {
     if (this.internalState !== BusState.Stopped) {
@@ -75,0 +75,0 @@ throw new Error('ServiceBus must be stopped to add useBforeHandleNextMessageMiddlewares')

No alert changes

Improved metrics

Total package byte prevSize

196744

increased by0.02%

No dependency changes