You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/10/20 02:54:01 UTC
[incubator-eventmesh] branch master updated: replace with constants
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new adf47765 replace with constants
new d5ebc336 Merge pull request #1644 from Pragalapavithra23/fix_patch_1154
adf47765 is described below
commit adf4776528c4b3dd6b11ce877abaf3ab8cdda40f
Author: pragalapavithra <pr...@thoughtworks.com>
AuthorDate: Tue Oct 18 14:27:38 2022 +0530
replace with constants
---
.../apache/eventmesh/protocol/http/HttpProtocolAdaptor.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java b/eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java
index 7a765857..5d8cb60b 100644
--- a/eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java
+++ b/eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java
@@ -36,6 +36,8 @@ import io.cloudevents.CloudEvent;
import com.fasterxml.jackson.core.type.TypeReference;
+import static org.apache.eventmesh.protocol.http.HttpProtocolConstant.*;
+
/**
* CloudEvents protocol adaptor, used to transform CloudEvents message to CloudEvents message.
*
@@ -93,12 +95,12 @@ public class HttpProtocolAdaptor<T extends ProtocolTransportObject>
Map<String, Object> dataContentMap = JsonUtils.deserialize(new String(cloudEvent.getData().toBytes(), Constants.DEFAULT_CHARSET),
new TypeReference<Map<String, Object>>() {});
- String requestHeader = JsonUtils.serialize(dataContentMap.get("headers"));
- byte[] requestBody = JsonUtils.serialize(dataContentMap.get("body")).getBytes(StandardCharsets.UTF_8);
+ String requestHeader = JsonUtils.serialize(dataContentMap.get(CONSTANTS_KEY_HEADERS));
+ byte[] requestBody = JsonUtils.serialize(dataContentMap.get(CONSTANTS_KEY_BODY)).getBytes(StandardCharsets.UTF_8);
Map<String, Object> requestHeaderMap = JsonUtils.deserialize(requestHeader, new TypeReference<Map<String, Object>>() {
});
- String requestURI = dataContentMap.get("path").toString();
- String httpMethod = dataContentMap.get("method").toString();
+ String requestURI = dataContentMap.get(CONSTANTS_KEY_PATH).toString();
+ String httpMethod = dataContentMap.get(CONSTANTS_KEY_METHOD).toString();
httpEventWrapper.setHeaderMap(requestHeaderMap);
httpEventWrapper.setBody(requestBody);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org