diff options
Diffstat (limited to 'weed/mq/broker/broker_server.go')
| -rw-r--r-- | weed/mq/broker/broker_server.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index db8329989..2ab20ac52 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -39,6 +39,7 @@ type MessageQueueBroker struct { localTopicManager *topic.LocalTopicManager Balancer *balancer.Balancer lockAsBalancer *cluster.LiveLock + currentBalancer pb.ServerAddress } func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.DialOption) (mqBroker *MessageQueueBroker, err error) { |