diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-05 15:14:25 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-05 15:14:25 -0800 |
| commit | ee41dbb7fcff189433e40f4944e5a2df889a9c7f (patch) | |
| tree | 18b92190c60073381b2efaac99d1f25653445997 /weed/mq/client | |
| parent | 1fed37bed005fdaee8b86e972d0521a713e2ab97 (diff) | |
| download | seaweedfs-ee41dbb7fcff189433e40f4944e5a2df889a9c7f.tar.xz seaweedfs-ee41dbb7fcff189433e40f4944e5a2df889a9c7f.zip | |
rename functions
Diffstat (limited to 'weed/mq/client')
| -rw-r--r-- | weed/mq/client/pub_client/connect.go | 8 | ||||
| -rw-r--r-- | weed/mq/client/pub_client/publish.go | 4 |
2 files changed, 6 insertions, 6 deletions
diff --git a/weed/mq/client/pub_client/connect.go b/weed/mq/client/pub_client/connect.go index fc7ff4d77..364d41560 100644 --- a/weed/mq/client/pub_client/connect.go +++ b/weed/mq/client/pub_client/connect.go @@ -21,7 +21,7 @@ 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.Publish(context.Background()) + stream, err := brokerClient.SubscribeMessage(context.Background()) if err != nil { return publishClient, fmt.Errorf("create publish client: %v", err) } @@ -29,9 +29,9 @@ func (p *TopicPublisher) doConnect(partition *mq_pb.Partition, brokerAddress str SeaweedMessaging_PublishClient: stream, Broker: brokerAddress, } - if err = publishClient.Send(&mq_pb.PublishRequest{ - Message: &mq_pb.PublishRequest_Init{ - Init: &mq_pb.PublishRequest_InitMessage{ + if err = publishClient.Send(&mq_pb.PublishMessageRequest{ + Message: &mq_pb.PublishMessageRequest_Init{ + Init: &mq_pb.PublishMessageRequest_InitMessage{ Topic: &mq_pb.Topic{ Namespace: p.namespace, Name: p.topic, diff --git a/weed/mq/client/pub_client/publish.go b/weed/mq/client/pub_client/publish.go index 1e250ede3..2f4367b9d 100644 --- a/weed/mq/client/pub_client/publish.go +++ b/weed/mq/client/pub_client/publish.go @@ -27,8 +27,8 @@ func (p *TopicPublisher) Publish(key, value []byte) error { //google.golang.org/grpc.(*clientStream).SendMsg(stream.go:894) //github.com/seaweedfs/seaweedfs/weed/pb/mq_pb.(*seaweedMessagingPublishClient).Send(mq_grpc.pb.go:141) //github.com/seaweedfs/seaweedfs/weed/mq/client/pub_client.(*TopicPublisher).Publish(publish.go:19) - if err := publishClient.Send(&mq_pb.PublishRequest{ - Message: &mq_pb.PublishRequest_Data{ + if err := publishClient.Send(&mq_pb.PublishMessageRequest{ + Message: &mq_pb.PublishMessageRequest_Data{ Data: &mq_pb.DataMessage{ Key: key, Value: value, |