diff options
Diffstat (limited to 'weed/mq/broker/broker_connect.go')
| -rw-r--r-- | weed/mq/broker/broker_connect.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/broker/broker_connect.go b/weed/mq/broker/broker_connect.go index 386d86570..c92fc299c 100644 --- a/weed/mq/broker/broker_connect.go +++ b/weed/mq/broker/broker_connect.go @@ -25,7 +25,7 @@ func (b *MessageQueueBroker) BrokerConnectToBalancer(brokerBalancer string, stop return pb.WithBrokerGrpcClient(true, brokerBalancer, b.grpcDialOption, func(client mq_pb.SeaweedMessagingClient) error { stream, err := client.PublisherToPubBalancer(context.Background()) if err != nil { - return fmt.Errorf("connect to balancer %v: %v", brokerBalancer, err) + return fmt.Errorf("connect to balancer %v: %w", brokerBalancer, err) } defer stream.CloseSend() err = stream.Send(&mq_pb.PublisherToPubBalancerRequest{ @@ -36,7 +36,7 @@ func (b *MessageQueueBroker) BrokerConnectToBalancer(brokerBalancer string, stop }, }) if err != nil { - return fmt.Errorf("send init message: %v", err) + return fmt.Errorf("send init message: %w", err) } for { |