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/07/12 06:31:55 UTC
[incubator-eventmesh] branch master updated: Modify the value of protocolType
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 d623db9d Modify the value of protocolType
new 9f077793 Merge pull request #1003 from kirinzhu/fix-zlx-2
d623db9d is described below
commit d623db9d1cecf1a89ed0e6fa80b312a0b0a0f21a
Author: kirinzhu <li...@outlook.com>
AuthorDate: Thu Jul 7 16:24:19 2022 +0800
Modify the value of protocolType
---
.../runtime/core/protocol/tcp/client/task/MessageTransferTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
index 944b2cb6..9886e9ae 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
@@ -100,7 +100,7 @@ public class MessageTransferTask extends AbstractTask {
CloudEvent event = null;
try {
- String protocolType = "EventMeshMessage";
+ String protocolType = "eventmeshmessage";
if (pkg.getHeader().getProperties() != null
&& pkg.getHeader().getProperty(Constants.PROTOCOL_TYPE) != null) {
protocolType = (String) pkg.getHeader().getProperty(Constants.PROTOCOL_TYPE);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org