diff options
Diffstat (limited to 'weed/mq/broker/broker_server.go')
| -rw-r--r-- | weed/mq/broker/broker_server.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index 89afb6e4d..4c86d813f 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -42,7 +42,7 @@ func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.Dial MasterClient: wdclient.NewMasterClient(grpcDialOption, option.FilerGroup, cluster.BrokerType, pb.NewServerAddress(option.Ip, option.Port, 0), option.DataCenter, option.Rack, option.Masters), filers: make(map[pb.ServerAddress]struct{}), } - mqBroker.MasterClient.OnPeerUpdate = mqBroker.OnBrokerUpdate + mqBroker.MasterClient.SetOnPeerUpdateFn(mqBroker.OnBrokerUpdate) go mqBroker.MasterClient.KeepConnectedToMaster() |