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/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 651fe9b33 [ISSUE 4209] Fix
event.getExtension(ProtocolKey.ClientInstanceKey.TOKEN) get null (#4225)
651fe9b33 is described below
commit 651fe9b33346c23efc4d75102ee69dd1b4eb4ebe
Author: Alonexc <[email protected]>
AuthorDate: Tue Jul 18 09:25:20 2023 +0800
[ISSUE 4209] Fix event.getExtension(ProtocolKey.ClientInstanceKey.TOKEN)
get null (#4225)
* Create .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* Update .lift.toml
* delete lift
* add token field
---
.../java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java
index 4dff89c67..579d22adf 100644
---
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java
@@ -207,6 +207,7 @@ public class HttpEventWrapper implements
ProtocolTransportObject {
headerMap.getOrDefault(ProtocolKey.ClientInstanceKey.CONSUMERGROUP,
"em-http-consumer"));
sysHeaderMap.put(ProtocolKey.PROTOCOL_TYPE, "http");
sysHeaderMap.put(ProtocolKey.PROTOCOL_DESC, "http");
+ sysHeaderMap.put(ProtocolKey.ClientInstanceKey.TOKEN,
headerMap.getOrDefault(ProtocolKey.ClientInstanceKey.TOKEN, "token"));
}
public void buildSysHeaderForCE() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]