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 94888e14c..2a6f2da1b 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -72,9 +72,9 @@ func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.Dial lockClient := cluster.NewLockClient(grpcDialOption, mqBroker.currentFiler) mqBroker.lockAsBalancer = lockClient.StartLock(balancer.LockBrokerBalancer, self) for { - err := mqBroker.BrokerConnectToBalancer(self) + err := mqBroker.BrokerConnectToPubCoordinator(self) if err != nil { - fmt.Printf("BrokerConnectToBalancer: %v\n", err) + fmt.Printf("BrokerConnectToPubCoordinator: %v\n", err) } time.Sleep(time.Second) } |