diff options
Diffstat (limited to 'weed/mq/broker/broker_server.go')
| -rw-r--r-- | weed/mq/broker/broker_server.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index a009af693..3a25a9691 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -92,8 +92,8 @@ func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.Dial glog.V(0).Infof("BrokerConnectToBalancer: %v", err) } time.Sleep(time.Second) - if err := mqBroker.lockAsBalancer.DoLock(lock_manager.MaxDuration); err != nil { - glog.V(0).Infof("DoLock: %v", err) + if err := mqBroker.lockAsBalancer.AttemptToLock(lock_manager.MaxDuration); err != nil { + glog.V(0).Infof("AttemptToLock: %v", err) } } }() |