From 57801687dee49239a61e7ced9fa02e48c47ae94c Mon Sep 17 00:00:00 2001
From: Lars Lehtonen <lars.lehtonen@gmail.com>
Date: Mon, 20 Nov 2023 04:57:38 -0800
Subject: [PATCH] weed/command: fix dropped error

---
 weed/command/mq_broker.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/weed/command/mq_broker.go b/weed/command/mq_broker.go
index aa327cb15..e093ebc56 100644
--- a/weed/command/mq_broker.go
+++ b/weed/command/mq_broker.go
@@ -78,6 +78,9 @@ func (mqBrokerOpt *MessageQueueBrokerOptions) startQueueServer() bool {
 		Ip:                 *mqBrokerOpt.ip,
 		Port:               *mqBrokerOpt.port,
 	}, grpcDialOption)
+	if err != nil {
+		glog.Fatalf("failed to create new message broker for queue server: %v", err)
+	}
 
 	// start grpc listener
 	grpcL, _, err := util.NewIpAndLocalListeners("", *mqBrokerOpt.port, 0)