diff --git a/lib/client/connection/rpc.js b/lib/client/connection/rpc.js index facd332..124f44a 100644 --- a/lib/client/connection/rpc.js +++ b/lib/client/connection/rpc.js @@ -96,11 +96,13 @@ class RpcConnection extends Base { sentReqs: this._sentReqs, classCache: this.options.classCache || new Map(), address: this.address, + logger: this.options.logger, }; const decodeOpts = { sentReqs: this._sentReqs, classCache: this.options.classCache || new Map(), address: this.address, + logger: this.options.logger, }; // 针对 classMap 针对 hessian, proto 针对 protobuf diff --git a/lib/server/connection.js b/lib/server/connection.js index b2e7729..4f20aa0 100644 --- a/lib/server/connection.js +++ b/lib/server/connection.js @@ -28,10 +28,12 @@ class RpcConnection extends Base { const encodeOpts = { sentReqs: this._sentReqs, classCache: this.options.classCache || new Map(), + logger: this.options.logger, }; const decodeOpts = { sentReqs: this._sentReqs, classCache: this.options.classCache || new Map(), + logger: this.options.logger, }; // 针对 classMap 针对 hessian, proto 针对 protobuf // 因为可能需要同时支持,所以分开设置(一般通过全局设置,所以这里要判断是否有值)