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 2023/06/07 02:47:09 UTC
[eventmesh] branch master updated: [ISSUE #4031] Specifies the default character set (#4057)
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 d182e55ae [ISSUE #4031] Specifies the default character set (#4057)
d182e55ae is described below
commit d182e55aeaf890eb5df0d0e749ecff681563cd9e
Author: Monty Mole <44...@users.noreply.github.com>
AuthorDate: Wed Jun 7 10:47:03 2023 +0800
[ISSUE #4031] Specifies the default character set (#4057)
---
.../apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java | 3 ++-
.../org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java b/eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java
index b42626f67..51bb19d06 100644
--- a/eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java
+++ b/eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java
@@ -17,6 +17,7 @@
package org.apache.eventmesh.storage.mongodb.utils;
+import org.apache.eventmesh.common.Constants;
import org.apache.eventmesh.storage.mongodb.exception.MongodbStorageException;
import java.net.URI;
@@ -44,7 +45,7 @@ public class MongodbCloudEventUtil {
default:
throw new MongodbStorageException(String.format("CloudEvent version %s does not support.", version));
}
- builder.withData(document.remove("data").toString().getBytes())
+ builder.withData(document.remove("data").toString().getBytes(Constants.DEFAULT_CHARSET))
.withId(document.remove("id").toString())
.withSource(URI.create(document.remove("source").toString()))
.withType(document.remove("type").toString())
diff --git a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java
index b506eca19..a362767ca 100644
--- a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java
+++ b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java
@@ -30,7 +30,7 @@ public class ByteArrayUtils {
public static <T> Optional<byte[]> objectToBytes(T obj) throws IOException {
String s = JsonUtils.toJSONString(obj);
- byte[] bytes = s.getBytes();
+ byte[] bytes = s.getBytes(Constants.DEFAULT_CHARSET);
return Optional.ofNullable(bytes);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org