diff options
Diffstat (limited to 'weed/mq/broker/broker_grpc_pub_follow.go')
| -rw-r--r-- | weed/mq/broker/broker_grpc_pub_follow.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_grpc_pub_follow.go b/weed/mq/broker/broker_grpc_pub_follow.go index 117dc4f87..d8f472249 100644 --- a/weed/mq/broker/broker_grpc_pub_follow.go +++ b/weed/mq/broker/broker_grpc_pub_follow.go @@ -53,7 +53,11 @@ func (b *MessageQueueBroker) PublishFollowMe(stream mq_pb.SeaweedMessaging_Publi // TODO: change this to DataMessage // log the message - logBuffer.AddToBuffer(dataMessage) + if addErr := logBuffer.AddToBuffer(dataMessage); addErr != nil { + err = fmt.Errorf("failed to add message to log buffer: %w", addErr) + glog.Errorf("Failed to add message to log buffer: %v", addErr) + break + } // send back the ack if err := stream.Send(&mq_pb.PublishFollowMeResponse{ |