This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/eventmesh-go.git
The following commit(s) were added to refs/heads/main by this push:
new 0a3b41a Update consumer_processor.go
new 770e333 Merge pull request #8 from harshithasudhakar/patch-2
0a3b41a is described below
commit 0a3b41ad7bd06cb99894a6aad39e02939721edd4
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Mon Apr 24 10:28:39 2023 +0530
Update consumer_processor.go
Replaced time.Now().Sub() with time.Since()
---
runtime/core/protocol/grpc/consumer/consumer_processor.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/runtime/core/protocol/grpc/consumer/consumer_processor.go
b/runtime/core/protocol/grpc/consumer/consumer_processor.go
index 67837d9..b5abb3b 100644
--- a/runtime/core/protocol/grpc/consumer/consumer_processor.go
+++ b/runtime/core/protocol/grpc/consumer/consumer_processor.go
@@ -290,12 +290,12 @@ func (p *processor) ReplyMessage(ctx context.Context,
producerMgr producer.Produ
&connector.SendCallback{
OnSuccess: func(result *connector.SendResult) {
log.Infof("message|mq2eventmesh|REPLY|ReplyToServer|send2MQCost=%vms|topic=%v|bizSeqNo=%v|uniqueId=%v",
- time.Now().Sub(start).Milliseconds(),
replyTopic, seqNum, uniqID)
+ time.Since(start).Milliseconds(),
replyTopic, seqNum, uniqID)
},
OnError: func(result *connector.ErrorResult) {
emiter.SendStreamResp(hdr,
grpc.EVENTMESH_REPLY_MSG_ERR)
log.Errorf("message|mq2eventmesh|REPLY|ReplyToServer|send2MQCost=%vms|topic=%v|bizSeqNo=%v|uniqueId=%v",
- time.Now().Sub(start).Milliseconds(),
replyTopic, seqNum, uniqID, result.Err)
+ time.Since(start).Milliseconds(),
replyTopic, seqNum, uniqID, result.Err)
},
},
)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
