diff options
Diffstat (limited to 'weed/command')
| -rw-r--r-- | weed/command/msg_broker.go | 6 | ||||
| -rw-r--r-- | weed/command/scaffold.go | 2 |
2 files changed, 1 insertions, 7 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 { diff --git a/weed/command/scaffold.go b/weed/command/scaffold.go index 67fa8dcf3..2c2bdc737 100644 --- a/weed/command/scaffold.go +++ b/weed/command/scaffold.go @@ -80,8 +80,6 @@ buckets_fsync = [ # a list of buckets with all write requests fsync=tru "important_bucket", "should_always_fsync", ] -# directories under this folder will be store message queue data -queues_folder = "/queues" #################################################### # The following are filer store options |