Correcting the Promise RPC Client options.

nutes-uepb · Mar 29, 2021 · 48f00a8 · 48f00a8
1 parent 63f1787
commit 48f00a8
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 6 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "amqp-client-node",
-  "version": "1.0.10",
+  "version": "1.0.11",
   "description": "Library for publish and subscribe events on message bus. In addition, it is possible to perform resource requests from the use of the standard commonly known as RPC.",
   "main": "lib/index.js",
   "typings": "lib/index.d.ts",

diff --git a/src/application/connection.ts b/src/application/connection.ts
@@ -123,7 +123,7 @@ export class Connection implements IConnection {
                      optOrCall?: IClientOptions | ((err, message: any) => void),
                      options?: IClientOptions): any {
         if (!(optOrCall instanceof Function)) {
-            return this.rpcClientPromise(exchangeName, resourceName, parameters, options)
+            return this.rpcClientPromise(exchangeName, resourceName, parameters, optOrCall)
         }
         this.rpcClientCallback(exchangeName, resourceName, parameters, optOrCall, options)
     }

diff --git a/src/application/port/communication.option.interface.ts b/src/application/port/communication.option.interface.ts
@@ -14,7 +14,7 @@ export interface ISubExchangeOptions {
 
 export interface IClientOptions {
     exchange?: IExchangeOptions,
-    rcpTimeout?: number
+    rpcTimeout?: number
 }
 
 export interface IServerOptions {

diff --git a/src/infrastructure/rabbitmq/rpc/client.register.rabbitmq.ts b/src/infrastructure/rabbitmq/rpc/client.register.rabbitmq.ts
@@ -8,7 +8,7 @@ import { IClientOptions } from '../../../application/port/communication.option.i
 import { IMessage } from '../../../application/port/message.interface'
 
 const defClientOptions: IClientOptions = {
-    rcpTimeout: 5000
+    rpcTimeout: 5000
 }
 
 @injectable()
@@ -35,8 +35,10 @@ export class ClientRegisterRabbitmq implements IClientRegister {
                 const exchange = this._connection.getExchange(exchangeName, options ? options.exchange : undefined)
                 await exchange.initialized
 
+                if (!options.rpcTimeout) options.rpcTimeout = defClientOptions.rpcTimeout
+
                 let time
-                const timeout = options.rcpTimeout
+                const timeout = options.rpcTimeout
 
                 if (timeout > 0) {
                     new Promise<any>((res) => {