diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-05 17:10:43 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-05 17:10:43 -0800 |
| commit | d0d24f1e40d6630124d82c6c7f17fc42049c58aa (patch) | |
| tree | 87bcc134331dbe98ce8582bd8c9dc24825a86307 | |
| parent | d9bd343055e4e2bab8329fa17b26b2ea72b0ab83 (diff) | |
| download | seaweedfs-d0d24f1e40d6630124d82c6c7f17fc42049c58aa.tar.xz seaweedfs-d0d24f1e40d6630124d82c6c7f17fc42049c58aa.zip | |
rename functions
| -rw-r--r-- | weed/mq/client/pub_client/connect.go | 4 | ||||
| -rw-r--r-- | weed/mq/client/pub_client/publisher.go | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/weed/mq/client/pub_client/connect.go b/weed/mq/client/pub_client/connect.go index 364d41560..4ff12737f 100644 --- a/weed/mq/client/pub_client/connect.go +++ b/weed/mq/client/pub_client/connect.go @@ -21,12 +21,12 @@ func (p *TopicPublisher) doConnect(partition *mq_pb.Partition, brokerAddress str return publishClient, fmt.Errorf("dial broker %s: %v", brokerAddress, err) } brokerClient := mq_pb.NewSeaweedMessagingClient(grpcConnection) - stream, err := brokerClient.SubscribeMessage(context.Background()) + stream, err := brokerClient.PublishMessage(context.Background()) if err != nil { return publishClient, fmt.Errorf("create publish client: %v", err) } publishClient = &PublishClient{ - SeaweedMessaging_PublishClient: stream, + SeaweedMessaging_PublishMessageClient: stream, Broker: brokerAddress, } if err = publishClient.Send(&mq_pb.PublishMessageRequest{ diff --git a/weed/mq/client/pub_client/publisher.go b/weed/mq/client/pub_client/publisher.go index a0c26db36..d5176f21b 100644 --- a/weed/mq/client/pub_client/publisher.go +++ b/weed/mq/client/pub_client/publisher.go @@ -17,7 +17,7 @@ type PublisherConfiguration struct { } type PublishClient struct { - mq_pb.SeaweedMessaging_PublishClient + mq_pb.SeaweedMessaging_PublishMessageClient Broker string Err error } |