Browse Source

rename parameter

mq-subscribe
chrislu 8 months ago
parent
commit
5324e4288a
  1. 9
      weed/mq/client/cmd/weed_pub/publisher.go
  2. 9
      weed/mq/client/pub_client/publisher.go
  3. 2
      weed/mq/client/pub_client/scheduler.go

9
weed/mq/client/cmd/weed_pub/publisher.go

@ -46,11 +46,10 @@ func doPublish(publisher *pub_client.TopicPublisher, id int) {
func main() { func main() {
flag.Parse() flag.Parse()
config := &pub_client.PublisherConfiguration{ config := &pub_client.PublisherConfiguration{
Topic: topic.NewTopic(*namespace, *t),
CreateTopic: true,
CreateTopicPartitionCount: int32(*partitionCount),
Brokers: strings.Split(*seedBrokers, ","),
PublisherName: *clientName,
Topic: topic.NewTopic(*namespace, *t),
PartitionCount: int32(*partitionCount),
Brokers: strings.Split(*seedBrokers, ","),
PublisherName: *clientName,
} }
publisher := pub_client.NewTopicPublisher(config) publisher := pub_client.NewTopicPublisher(config)

9
weed/mq/client/pub_client/publisher.go

@ -13,11 +13,10 @@ import (
) )
type PublisherConfiguration struct { type PublisherConfiguration struct {
Topic topic.Topic
CreateTopic bool
CreateTopicPartitionCount int32
Brokers []string
PublisherName string // for debugging
Topic topic.Topic
PartitionCount int32
Brokers []string
PublisherName string // for debugging
} }
type PublishClient struct { type PublishClient struct {

2
weed/mq/client/pub_client/scheduler.go

@ -235,7 +235,7 @@ func (p *TopicPublisher) doConfigureTopic() (err error) {
func(client mq_pb.SeaweedMessagingClient) error { func(client mq_pb.SeaweedMessagingClient) error {
_, err := client.ConfigureTopic(context.Background(), &mq_pb.ConfigureTopicRequest{ _, err := client.ConfigureTopic(context.Background(), &mq_pb.ConfigureTopicRequest{
Topic: p.config.Topic.ToPbTopic(), Topic: p.config.Topic.ToPbTopic(),
PartitionCount: p.config.CreateTopicPartitionCount,
PartitionCount: p.config.PartitionCount,
}) })
return err return err
}) })

Loading…
Cancel
Save