diff --git a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
index f06b249a6b..5c3dff2f0a 100755
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
@@ -230,6 +230,7 @@ func (c *client) Send(ctx context.Context, msg Message) error {
 
 	worker, err := c.getWorker()
 	if err != nil {
+		c.metrics.incMessage(workerBusy.getStrCode())
 		return ErrNoAvailableWorker
 	}
 	return worker.send(ctx, msg)
@@ -249,6 +250,7 @@ func (c *client) SendAsync(ctx context.Context, msg Message, cb Callback) {
 		if cb != nil {
 			cb(msg, ErrNoAvailableWorker)
 		}
+		c.metrics.incMessage(workerBusy.getStrCode())
 		return
 	}