|
@ -3,8 +3,8 @@ package msgclient |
|
|
import ( |
|
|
import ( |
|
|
"context" |
|
|
"context" |
|
|
"io" |
|
|
"io" |
|
|
"time" |
|
|
|
|
|
"sync" |
|
|
"sync" |
|
|
|
|
|
"time" |
|
|
|
|
|
|
|
|
"github.com/chrislusf/seaweedfs/weed/messaging/broker" |
|
|
"github.com/chrislusf/seaweedfs/weed/messaging/broker" |
|
|
"github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" |
|
|
"github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" |
|
@ -26,7 +26,7 @@ func (mc *MessagingClient) NewSubscriber(subscriberId, namespace, topic string, |
|
|
subscriberCancels := make([]context.CancelFunc, topicConfiguration.PartitionCount) |
|
|
subscriberCancels := make([]context.CancelFunc, topicConfiguration.PartitionCount) |
|
|
|
|
|
|
|
|
for i := 0; i < int(topicConfiguration.PartitionCount); i++ { |
|
|
for i := 0; i < int(topicConfiguration.PartitionCount); i++ { |
|
|
if partitionId>=0 && i != partitionId { |
|
|
|
|
|
|
|
|
if partitionId >= 0 && i != partitionId { |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
tp := broker.TopicPartition{ |
|
|
tp := broker.TopicPartition{ |
|
|