diff --git a/mq/proto/mq.pb.go b/mq/proto/mq.pb.go index a0e5cb9..45ca2e2 100644 --- a/mq/proto/mq.pb.go +++ b/mq/proto/mq.pb.go @@ -21,7 +21,7 @@ const ( _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) -// Publish a message to the mq. Specify a topic to group messages for a specific topic. +// Publish a message. Specify a topic to group messages for a specific topic. type PublishRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -166,7 +166,6 @@ func (x *SubscribeRequest) GetTopic() string { return "" } -// A blocking mq will be returned in response. type SubscribeResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache diff --git a/mq/proto/mq.proto b/mq/proto/mq.proto index c369cc0..359c000 100644 --- a/mq/proto/mq.proto +++ b/mq/proto/mq.proto @@ -11,7 +11,7 @@ service Mq { } // Publish a message. Specify a topic to group messages for a specific topic. -message PublishReque st { +message PublishRequest { // The topic to publish to string topic = 1; // The json message to publish