optimized returned reply in subscribe method

apache · Jan 19, 2024 · 98bf805 · 98bf805
1 parent 42c0d06
commit 98bf805
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/eventmesh-sdks/eventmesh-sdk-rust/src/grpc/grpc_consumer.rs b/eventmesh-sdks/eventmesh-sdk-rust/src/grpc/grpc_consumer.rs
@@ -161,12 +161,11 @@ impl EventMeshGrpcConsumer {
                             ProtocolKey::SUB_MESSAGE_TYPE.to_string(),
                             PbCloudEventAttributeValue {
                                 attr: Some(PbAttr::CeString(
-                                    SubscriptionReply::SUB_TYPE.to_string(),
+                                    ProtocolKey::SUB_REPLY_MESSAGE.to_string(),
                                 )),
                             },
                         );
-                        received.data =
-                            Some(PbData::TextData(serde_json::to_string(&reply).unwrap()));
+                        received.data = None;
                         let _ = keeper.sender.send(received).await;
                     }
                 } else {