diff options
Diffstat (limited to 'weed/messaging/broker/broker_server.go')
| -rw-r--r-- | weed/messaging/broker/broker_server.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/messaging/broker/broker_server.go b/weed/messaging/broker/broker_server.go index e6ff2cf00..0c04d2841 100644 --- a/weed/messaging/broker/broker_server.go +++ b/weed/messaging/broker/broker_server.go @@ -24,7 +24,7 @@ type MessageBrokerOption struct { type MessageBroker struct { option *MessageBrokerOption grpcDialOption grpc.DialOption - topicLocks *TopicLocks + topicManager *TopicManager } func NewMessageBroker(option *MessageBrokerOption, grpcDialOption grpc.DialOption) (messageBroker *MessageBroker, err error) { @@ -34,7 +34,7 @@ func NewMessageBroker(option *MessageBrokerOption, grpcDialOption grpc.DialOptio grpcDialOption: grpcDialOption, } - messageBroker.topicLocks = NewTopicLocks(messageBroker) + messageBroker.topicManager = NewTopicManager(messageBroker) messageBroker.checkFilers() @@ -58,7 +58,7 @@ func (broker *MessageBroker) keepConnectedToOneFiler() { Name: broker.option.Ip, GrpcPort: uint32(broker.option.Port), } - for _, tp := range broker.topicLocks.ListTopicPartitions() { + for _, tp := range broker.topicManager.ListTopicPartitions() { initRequest.Resources = append(initRequest.Resources, tp.String()) } if err := stream.Send(&filer_pb.KeepConnectedRequest{ |