multiple subscriber with same subscriberId shares the topic manager

rename topicControl to topicCursor

1 files changed, 2 insertions, 2 deletions

diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/sub_chan.go
index ed25a850c..5465c5913 100644
--- a/weed/messaging/msgclient/sub_chan.go
+++ b/weed/messaging/msgclient/sub_chan.go
@@ -17,7 +17,7 @@ type SubChannel struct {
 	md5hash hash.Hash
 }
 
-func (mc *MessagingClient) NewSubChannel(chanName string) (*SubChannel, error) {
+func (mc *MessagingClient) NewSubChannel(subscriberId, chanName string) (*SubChannel, error) {
 	tp := broker.TopicPartition{
 		Namespace: "chan",
 		Topic:     chanName,
@@ -27,7 +27,7 @@ func (mc *MessagingClient) NewSubChannel(chanName string) (*SubChannel, error) {
 	if err != nil {
 		return nil, err
 	}
-	sc, err := setupSubscriberClient(grpcConnection, "", "chan", chanName, 0, time.Unix(0, 0))
+	sc, err := setupSubscriberClient(grpcConnection, subscriberId, "chan", chanName, 0, time.Unix(0, 0))
 	if err != nil {
 		return nil, err
 	}