diff options
Diffstat (limited to 'weed/shell/command_mq_topic_list.go')
| -rw-r--r-- | weed/shell/command_mq_topic_list.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/shell/command_mq_topic_list.go b/weed/shell/command_mq_topic_list.go index 5fb913a8a..cf6b97e96 100644 --- a/weed/shell/command_mq_topic_list.go +++ b/weed/shell/command_mq_topic_list.go @@ -3,7 +3,7 @@ package shell import ( "context" "fmt" - "github.com/seaweedfs/seaweedfs/weed/mq/balancer" + "github.com/seaweedfs/seaweedfs/weed/mq/pub_balancer" "github.com/seaweedfs/seaweedfs/weed/pb" "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" @@ -52,7 +52,7 @@ func (c *commandMqTopicList) Do(args []string, commandEnv *CommandEnv, writer io func findBrokerBalancer(commandEnv *CommandEnv) (brokerBalancer string, err error) { err = commandEnv.WithFilerClient(false, func(client filer_pb.SeaweedFilerClient) error { resp, err := client.FindLockOwner(context.Background(), &filer_pb.FindLockOwnerRequest{ - Name: balancer.LockBrokerBalancer, + Name: pub_balancer.LockBrokerBalancer, }) if err != nil { return err |