diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-12 13:07:59 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-12 13:07:59 -0700 |
| commit | 6f948e48879ed0706b044bea0429d3fc48d6e8e1 (patch) | |
| tree | d9303cccaa43dc011070194aae584a70e7ec6d15 /weed/command/msg_broker.go | |
| parent | 94e35cdb3552498b25824950bde94334c8b25331 (diff) | |
| download | seaweedfs-6f948e48879ed0706b044bea0429d3fc48d6e8e1.tar.xz seaweedfs-6f948e48879ed0706b044bea0429d3fc48d6e8e1.zip | |
remove configurable topics folder location
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 { |