diff --git a/rpc/ws/client.go b/rpc/ws/client.go index 52ec278..46c3605 100644 --- a/rpc/ws/client.go +++ b/rpc/ws/client.go @@ -89,11 +89,12 @@ func (c *Client) handleMessage(message []byte) { func (c *Client) handleNewSubscriptionMessage(requestID, subID uint64) { c.lock.Lock() defer c.lock.Unlock() - - zlog.Info("received new subscription message", - zap.Uint64("message_id", requestID), - zap.Uint64("subscription_id", subID), - ) + if traceEnabled { + zlog.Debug("received new subscription message", + zap.Uint64("message_id", requestID), + zap.Uint64("subscription_id", subID), + ) + } callBack, found := c.subscriptionByRequestID[requestID] if !found { zlog.Error("cannot find websocket message handler for a new stream.... this should not happen",