You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/11/25 07:02:16 UTC
[rocketmq-clients] branch master updated: golang: add more log for debug mode (#292)
This is an automated email from the ASF dual-hosted git repository.
kaili pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 5ba0ba13 golang: add more log for debug mode (#292)
5ba0ba13 is described below
commit 5ba0ba13e7732fabe2976d52418f9b52c34dae11
Author: guyinyou <36...@users.noreply.github.com>
AuthorDate: Fri Nov 25 15:02:11 2022 +0800
golang: add more log for debug mode (#292)
Co-authored-by: guyinyou <gu...@alibaba-inc.com>
---
golang/rpc_client.go | 32 ++++++++++++++++++++++++--------
golang/simple_consumer.go | 1 +
2 files changed, 25 insertions(+), 8 deletions(-)
diff --git a/golang/rpc_client.go b/golang/rpc_client.go
index fe64dc9f..5ea838eb 100644
--- a/golang/rpc_client.go
+++ b/golang/rpc_client.go
@@ -96,12 +96,16 @@ func (rc *rpcClient) GracefulStop() error {
func (rc *rpcClient) QueryRoute(ctx context.Context, request *v2.QueryRouteRequest) (*v2.QueryRouteResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.QueryRoute(ctx, request)
+ resp, err := rc.msc.QueryRoute(ctx, request)
+ sugarBaseLogger.Debugf("queryRoute request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) SendMessage(ctx context.Context, request *v2.SendMessageRequest) (*v2.SendMessageResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.SendMessage(ctx, request)
+ resp, err := rc.msc.SendMessage(ctx, request)
+ sugarBaseLogger.Debugf("sendMessage request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) Telemetry(ctx context.Context) (v2.MessagingService_TelemetryClient, error) {
@@ -110,30 +114,42 @@ func (rc *rpcClient) Telemetry(ctx context.Context) (v2.MessagingService_Telemet
func (rc *rpcClient) EndTransaction(ctx context.Context, request *v2.EndTransactionRequest) (*v2.EndTransactionResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.EndTransaction(ctx, request)
+ resp, err := rc.msc.EndTransaction(ctx, request)
+ sugarBaseLogger.Debugf("endTransaction request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) HeartBeat(ctx context.Context, request *v2.HeartbeatRequest) (*v2.HeartbeatResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.Heartbeat(ctx, request)
+ resp, err := rc.msc.Heartbeat(ctx, request)
+ sugarBaseLogger.Debugf("heartBeat request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) NotifyClientTermination(ctx context.Context, request *v2.NotifyClientTerminationRequest) (*v2.NotifyClientTerminationResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.NotifyClientTermination(ctx, request)
+ resp, err := rc.msc.NotifyClientTermination(ctx, request)
+ sugarBaseLogger.Debugf("notifyClientTermination request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) ReceiveMessage(ctx context.Context, request *v2.ReceiveMessageRequest) (v2.MessagingService_ReceiveMessageClient, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.ReceiveMessage(ctx, request)
+ resp, err := rc.msc.ReceiveMessage(ctx, request)
+ sugarBaseLogger.Debugf("receiveMessage request: %v, err: %v", request, err)
+ return resp, err
}
func (rc *rpcClient) AckMessage(ctx context.Context, request *v2.AckMessageRequest) (*v2.AckMessageResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.AckMessage(ctx, request)
+ resp, err := rc.msc.AckMessage(ctx, request)
+ sugarBaseLogger.Debugf("ackMessage request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
func (rc *rpcClient) ChangeInvisibleDuration(ctx context.Context, request *v2.ChangeInvisibleDurationRequest) (*v2.ChangeInvisibleDurationResponse, error) {
rc.activityNanoTime = time.Now()
- return rc.msc.ChangeInvisibleDuration(ctx, request)
+ resp, err := rc.msc.ChangeInvisibleDuration(ctx, request)
+ sugarBaseLogger.Debugf("changeInvisibleDuration request: %v, response: %v, err: %v", request, resp, err)
+ return resp, err
}
diff --git a/golang/simple_consumer.go b/golang/simple_consumer.go
index 57ba0252..fe8c7734 100644
--- a/golang/simple_consumer.go
+++ b/golang/simple_consumer.go
@@ -210,6 +210,7 @@ func (sc *defaultSimpleConsumer) receiveMessage(ctx context.Context, request *v2
sc.cli.log.Errorf("simpleConsumer recv msg err=%w, requestId=%s", err, utils.GetRequestID(ctx))
break
}
+ sugarBaseLogger.Debugf("receiveMessage response: %v", resp)
resps = append(resps, resp)
}
cancel()