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/12/02 02:41:39 UTC
[incubator-eventmesh] branch master updated: fix issue2347
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 315b9358f fix issue2347
new 807d35c45 Merge pull request #2356 from jonyangx/issue2347
315b9358f is described below
commit 315b9358fdeb8703c674ac67c1fbd19dad880928
Author: jonyangx <jo...@gmail.com>
AuthorDate: Fri Dec 2 09:32:18 2022 +0800
fix issue2347
---
.../eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java b/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
index aba79a140..1e5a3969a 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
@@ -24,6 +24,7 @@ import org.apache.eventmesh.api.exception.OnExceptionContext;
import org.apache.eventmesh.connector.rabbitmq.RabbitmqServer;
import java.net.URI;
+import java.nio.charset.StandardCharsets;
import java.time.OffsetDateTime;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
@@ -68,7 +69,7 @@ public class RabbitmqConsumerTest extends RabbitmqServer {
.withSubject("topic")
.withType(String.class.getCanonicalName())
.withDataContentType("text/plain")
- .withData("data".getBytes())
+ .withData("data".getBytes(StandardCharsets.UTF_8))
.build();
rabbitmqProducer.publish(cloudEvent, new SendCallback() {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org