diff options
Diffstat (limited to 'weed/command/msg_broker.go')
| -rw-r--r-- | weed/command/msg_broker.go | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go index 3e13b4730..093cff4a6 100644 --- a/weed/command/msg_broker.go +++ b/weed/command/msg_broker.go @@ -62,18 +62,14 @@ func (msgBrokerOpt *QueueOptions) startQueueServer() bool { return false } - filerQueuesPath := "/queues" - grpcDialOption := security.LoadClientTLS(util.GetViper(), "grpc.client") for { err = pb.WithGrpcFilerClient(filerGrpcAddress, grpcDialOption, func(client filer_pb.SeaweedFilerClient) error { - resp, err := client.GetFilerConfiguration(context.Background(), &filer_pb.GetFilerConfigurationRequest{}) + _, err := client.GetFilerConfiguration(context.Background(), &filer_pb.GetFilerConfigurationRequest{}) if err != nil { return fmt.Errorf("get filer %s configuration: %v", filerGrpcAddress, err) } - filerQueuesPath = resp.DirQueues - glog.V(0).Infof("Queue read filer queues dir: %s", filerQueuesPath) return nil }) if err != nil { |