This commit is contained in:
Asim Aslam
2021-11-02 14:50:48 +00:00
parent ee33bd2579
commit 455bcf0e5d
2 changed files with 2 additions and 3 deletions

View File

@@ -21,7 +21,7 @@ const (
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) _ = 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 { type PublishRequest struct {
state protoimpl.MessageState state protoimpl.MessageState
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache
@@ -166,7 +166,6 @@ func (x *SubscribeRequest) GetTopic() string {
return "" return ""
} }
// A blocking mq will be returned in response.
type SubscribeResponse struct { type SubscribeResponse struct {
state protoimpl.MessageState state protoimpl.MessageState
sizeCache protoimpl.SizeCache sizeCache protoimpl.SizeCache

View File

@@ -11,7 +11,7 @@ service Mq {
} }
// Publish a message. Specify a topic to group messages for a specific topic. // Publish a message. Specify a topic to group messages for a specific topic.
message PublishReque st { message PublishRequest {
// The topic to publish to // The topic to publish to
string topic = 1; string topic = 1;
// The json message to publish // The json message to publish