From 455bcf0e5d731d4eaf42a18094b922fdac15b0d7 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Tue, 2 Nov 2021 14:50:48 +0000 Subject: [PATCH] fix prot --- mq/proto/mq.pb.go | 3 +-- mq/proto/mq.proto | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) 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