aboutsummaryrefslogtreecommitdiff
path: root/weed/shell
diff options
context:
space:
mode:
Diffstat (limited to 'weed/shell')
-rw-r--r--weed/shell/command_mq_topic_desc.go1
-rw-r--r--weed/shell/command_mq_topic_list.go2
2 files changed, 1 insertions, 2 deletions
diff --git a/weed/shell/command_mq_topic_desc.go b/weed/shell/command_mq_topic_desc.go
index a4bf805f9..cedad6ed4 100644
--- a/weed/shell/command_mq_topic_desc.go
+++ b/weed/shell/command_mq_topic_desc.go
@@ -46,7 +46,6 @@ func (c *commandMqTopicDescribe) Do(args []string, commandEnv *CommandEnv, write
Namespace: *namespace,
Name: *topicName,
},
- IsForPublish: false,
})
if err != nil {
return err
diff --git a/weed/shell/command_mq_topic_list.go b/weed/shell/command_mq_topic_list.go
index cf6b97e96..0a193cb4e 100644
--- a/weed/shell/command_mq_topic_list.go
+++ b/weed/shell/command_mq_topic_list.go
@@ -55,7 +55,7 @@ func findBrokerBalancer(commandEnv *CommandEnv) (brokerBalancer string, err erro
Name: pub_balancer.LockBrokerBalancer,
})
if err != nil {
- return err
+ return fmt.Errorf("FindLockOwner: %v", err)
}
brokerBalancer = resp.Owner
return nil