This is an automated email from the ASF dual-hosted git repository.
mytang0 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 489c52ee1 fixes #3258
new c18f7af18 Merge pull request #3334 from nikam14/patch-9
489c52ee1 is described below
commit 489c52ee16b4bbe49a648a71b8cdc4ad8a139c19
Author: maheshnikam <[email protected]>
AuthorDate: Fri Mar 3 09:44:49 2023 +0000
fixes #3258
fixed Null pointer exception error.
---
.../apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
index 7c15cf3a8..6dc714a71 100644
---
a/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
+++
b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
@@ -35,6 +35,7 @@ import java.nio.charset.StandardCharsets;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
+import java.util.Objects;
import org.junit.Test;
@@ -110,7 +111,7 @@ public class EventMeshClientUtilTest {
.hasFieldOrPropertyWithValue("seqNum",
cloudEvent.getExtension(ProtocolKey.SEQ_NUM))
.hasFieldOrPropertyWithValue("uniqueId",
cloudEvent.getExtension(ProtocolKey.UNIQUE_ID))
.hasFieldOrPropertyWithValue("content", new String(
-
EventFormatProvider.getInstance().resolveFormat(JsonFormat.CONTENT_TYPE).serialize(cloudEvent),
+
Objects.requireNonNull(EventFormatProvider.getInstance().resolveFormat(JsonFormat.CONTENT_TYPE)).serialize(cloudEvent),
StandardCharsets.UTF_8));
}
@@ -144,7 +145,7 @@ public class EventMeshClientUtilTest {
.hasFieldOrPropertyWithValue("topic",
cloudEvents.get(0).getSubject())
.hasFieldOrPropertyWithValue("producerGroup",
clientConfig.getProducerGroup());
assertThat(batchMessage.getMessageItemList()).hasSize(1).first().hasFieldOrPropertyWithValue("content",
- new
String(EventFormatProvider.getInstance().resolveFormat(JsonFormat.CONTENT_TYPE)
+ new
String(Objects.requireNonNull(EventFormatProvider.getInstance().resolveFormat(JsonFormat.CONTENT_TYPE))
.serialize(cloudEvents.get(0)), StandardCharsets.UTF_8))
.hasFieldOrPropertyWithValue("ttl", "4000")
.hasFieldOrPropertyWithValue("seqNum",
cloudEvents.get(0).getExtension(ProtocolKey.SEQ_NUM))
@@ -172,4 +173,4 @@ public class EventMeshClientUtilTest {
.hasFieldOrPropertyWithValue("seqNum",
firstMeshMessage.getBizSeqNo())
.hasFieldOrPropertyWithValue("ttl",
firstMeshMessage.getProp(Constants.EVENTMESH_MESSAGE_CONST_TTL));
}
-}
\ No newline at end of file
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
