fix: remove broker when event callback

addapptables · Mar 13, 2023 · c43ce68 · c43ce68
1 parent 7fbfe4c
commit c43ce68
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packages/microservice/package.json b/packages/microservice/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@addapptables/microservice",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "description": "addapptables microservice",
   "author": "dev@addapptables.com",
   "homepage": "https://github.com/addapptables/miscellaneous#readme",

diff --git a/packages/microservice/src/services/broker/broker.service.ts b/packages/microservice/src/services/broker/broker.service.ts
@@ -33,11 +33,11 @@ export class BrokerService implements OnModuleDestroy {
   private subscribe = async (data: ITransferData<TransferDataDto>) => {
     const brokers = Broker.getInstance();
     const handle = brokers.get(data.cid);
+    brokers.delete(data.cid);
     if (typeof handle !== 'function') {
       return;
     }
     await handle(data);
-    brokers.delete(data.cid);
   };
 
   start(): IBrokerStart {