diff options
Diffstat (limited to 'weed/mq/client/cmd')
| -rw-r--r-- | weed/mq/client/cmd/weed_sub/subscriber.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/mq/client/cmd/weed_sub/subscriber.go b/weed/mq/client/cmd/weed_sub/subscriber.go index a175c948a..6d0e49be1 100644 --- a/weed/mq/client/cmd/weed_sub/subscriber.go +++ b/weed/mq/client/cmd/weed_sub/subscriber.go @@ -5,6 +5,7 @@ import ( "fmt" "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/mq/client/sub_client" + "github.com/seaweedfs/seaweedfs/weed/mq/topic" "github.com/seaweedfs/seaweedfs/weed/util" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" @@ -14,7 +15,7 @@ import ( var ( namespace = flag.String("ns", "test", "namespace") - topic = flag.String("topic", "test", "topic") + t = flag.String("topic", "test", "topic") seedBrokers = flag.String("brokers", "localhost:17777", "seed brokers") clientId = flag.Uint("client_id", uint(util.RandomInt32()), "client id") @@ -31,8 +32,7 @@ func main() { } contentConfig := &sub_client.ContentConfiguration{ - Namespace: *namespace, - Topic: *topic, + Topic: topic.NewTopic(*namespace, *t), Filter: "", StartTime: time.Unix(1, 1), } |