diff --git a/utils/grcputils.go b/utils/grcputils.go index b25b92e6..8a077737 100644 --- a/utils/grcputils.go +++ b/utils/grcputils.go @@ -496,10 +496,10 @@ func createSubscribeStreamPb(protoMessage *pb.SubscribeStreamMessage, messageMap if messageMap["action"] == "subscribe" { // RESPONSE protoMessage.MType = pb.SubscribeResponseType_RESPONSE protoMessage.Response = &pb.SubscribeStreamMessage_SubscribeResponseMessage{} - protoMessage.Response.SubscriptionId = messageMap["subscriptionId"].(string) protoMessage.Response.RequestId = messageMap["requestId"].(string) protoMessage.Response.Ts = messageMap["ts"].(string) if messageMap["error"] == nil { + protoMessage.Response.SubscriptionId = messageMap["subscriptionId"].(string) protoMessage.Status = pb.ResponseStatus_SUCCESS } else { protoMessage.Status = pb.ResponseStatus_ERROR