Skip to content
Permalink
Browse files
on trace trycatch err not all failed err
  • Loading branch information
hufeng committed Jul 3, 2018
1 parent 41579f9 commit 3736ee15b9af23d30731414aa965172e64c68eea
Showing 1 changed file with 1 addition and 1 deletion.
@@ -152,7 +152,6 @@ export class Queue implements IObservable<TQueueObserver> {
ctx.cleanTimeout();
ctx.reject(err);
this._clear(requestId);
traceErr(err);
}

consume(requestId: TRequestId, node: SocketWorker, providerMeta: DubboUrl) {
@@ -172,6 +171,7 @@ export class Queue implements IObservable<TQueueObserver> {
node.write(ctx);
} catch (err) {
this.failed(requestId, err);
traceErr(err);
}
if (isDevEnv) {
log(`current schedule queue ==>`, this.scheduleQueue);

1 comment on commit 3736ee1

@hufeng
Copy link
Member Author

@hufeng hufeng commented on 3736ee1 Jul 3, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

只记录consum方法调用过程中的异常,不去记录每次failed的err信息

Please sign in to comment.