From e7c071da971bde4f8c8918d30174c6a2c2d0e251 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Tue, 2 Nov 2021 13:56:04 +0000
Subject: [PATCH] fix mq

---
 mq/handler/mq.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/mq/handler/mq.go b/mq/handler/mq.go
index 6d9038d..a44d559 100644
--- a/mq/handler/mq.go
+++ b/mq/handler/mq.go
@@ -41,7 +41,7 @@ func (mq *MQ) Publish(ctx context.Context, req *pb.PublishRequest, rsp *pb.Publi
 	return nil
 }
 
-func (mq *MQ) Subscribe(ctx context.Context, req *pb.SubscribeRequest, mq pb.MQ_SubscribeStream) error {
+func (mq *MQ) Subscribe(ctx context.Context, req *pb.SubscribeRequest, stream pb.MQ_SubscribeStream) error {
 	if len(req.Topic) == 0 {
 		return errors.BadRequest("mq.publish", "topic is blank")
 	}
@@ -69,7 +69,7 @@ func (mq *MQ) Subscribe(ctx context.Context, req *pb.SubscribeRequest, mq pb.MQ_
 		d := &structpb.Struct{}
 		d.UnmarshalJSON(msg)
 
-		if err := mq.Send(&pb.SubscribeResponse{
+		if err := stream.Send(&pb.SubscribeResponse{
 			Topic:   req.Topic,
 			Message: d,
 		}); err != nil {