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 a18e4a0fe [ISSUE #3950]Add MessageUtils unit test case (#3951)
a18e4a0fe is described below
commit a18e4a0fe004c25ca899fe1804cc8e9f6bd63f61
Author: mxsm <[email protected]>
AuthorDate: Mon May 22 11:16:24 2023 +0800
[ISSUE #3950]Add MessageUtils unit test case (#3951)
---
.../client/tcp/common/MessageUtilsTest.java | 167 +++++++++++++++++++++
1 file changed, 167 insertions(+)
diff --git
a/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/MessageUtilsTest.java
b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/MessageUtilsTest.java
new file mode 100644
index 000000000..d9f3406b9
--- /dev/null
+++
b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/MessageUtilsTest.java
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.client.tcp.common;
+
+import org.apache.eventmesh.common.Constants;
+import org.apache.eventmesh.common.protocol.SubscriptionMode;
+import org.apache.eventmesh.common.protocol.SubscriptionType;
+import org.apache.eventmesh.common.protocol.tcp.Command;
+import org.apache.eventmesh.common.protocol.tcp.EventMeshMessage;
+import org.apache.eventmesh.common.protocol.tcp.Header;
+import org.apache.eventmesh.common.protocol.tcp.Package;
+import org.apache.eventmesh.common.protocol.tcp.Subscription;
+import org.apache.eventmesh.common.protocol.tcp.UserAgent;
+
+import java.util.UUID;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+
+public class MessageUtilsTest {
+
+ @Test
+ public void testHello() {
+ // Positive Test Case
+ UserAgent user = new UserAgent();
+ Package msg = MessageUtils.hello(user);
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.HELLO_REQUEST);
+ Assert.assertNotNull(msg.getBody());
+ Assert.assertTrue(msg.getBody() instanceof UserAgent);
+ // Negative Test Case
+ user = null;
+ try {
+ msg = null;
+ msg = MessageUtils.hello(user);
+
+ } catch (Exception e) {
+ Assert.assertNull(msg);
+ }
+ }
+
+ @Test
+ public void testHeartBeat() {
+ // Positive Test Case
+ Package msg = MessageUtils.heartBeat();
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.HEARTBEAT_REQUEST);
+ Assert.assertNull(msg.getBody());
+ // Negative Test Case
+ msg = null;
+ Assert.assertNull(msg);
+ }
+
+ @Test
+ public void testGoodbye() {
+ // Positive Test Case
+ Package msg = MessageUtils.goodbye();
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.CLIENT_GOODBYE_REQUEST);
+ Assert.assertNull(msg.getBody());
+ // Negative Test Case
+ msg = null;
+ Assert.assertNull(msg);
+ }
+
+ @Test
+ public void testListen() {
+ // Positive Test Case
+ Package msg = MessageUtils.listen();
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.LISTEN_REQUEST);
+ Assert.assertNull(msg.getBody());
+ // Negative Test Case
+ msg = null;
+ Assert.assertNull(msg);
+ }
+
+ @Test
+ public void testSubscribe() {
+ // Positive Test Case
+ String topic = "testTopic";
+ SubscriptionMode subscriptionMode = SubscriptionMode.CLUSTERING;
+ SubscriptionType subscriptionType = SubscriptionType.SYNC;
+ Package msg = MessageUtils.subscribe(topic, subscriptionMode,
subscriptionType);
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.SUBSCRIBE_REQUEST);
+ Assert.assertNotNull(msg.getBody());
+ Assert.assertTrue(msg.getBody() instanceof Subscription);
+ // Negative Test Case
+ topic = null;
+ subscriptionMode = null;
+ subscriptionType = null;
+ try {
+ msg = null;
+ msg = MessageUtils.subscribe(topic, subscriptionMode,
subscriptionType);
+
+ } catch (Exception e) {
+ Assert.assertNull(msg);
+ }
+ }
+
+ @Test
+ public void testUnsubscribe() {
+ // Positive Test Case
+ Package msg = MessageUtils.unsubscribe();
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.UNSUBSCRIBE_REQUEST);
+ Assert.assertNull(msg.getBody());
+ // Negative Test Case
+ msg = null;
+ Assert.assertNull(msg);
+ }
+
+ @Test
+ public void testAsyncMessageAck() {
+ // Positive Test Case
+ Package in = new Package();
+ Header header = new Header(Command.ASYNC_MESSAGE_TO_CLIENT_ACK, 0,
null, UUID.randomUUID().toString());
+ in.setHeader(header);
+ in.setBody("testBody");
+ Package msg = MessageUtils.asyncMessageAck(in);
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(),
Command.ASYNC_MESSAGE_TO_CLIENT_ACK);
+ Assert.assertEquals(msg.getHeader().getSeq(), in.getHeader().getSeq());
+ Assert.assertNotNull(msg.getBody());
+ Assert.assertEquals(msg.getBody(), in.getBody());
+ // Negative Test Case
+ in = null;
+ msg = null;
+ try {
+ msg = MessageUtils.asyncMessageAck(in);
+ } catch (Exception e) {
+ Assert.assertNull(msg);
+ }
+ }
+
+ @Test
+ public void testBuildPackage() {
+ // Positive Test Case
+ EventMeshMessage eventMeshMessage = new EventMeshMessage();
+ eventMeshMessage.setBody("111");
+ Command command = Command.ASYNC_MESSAGE_TO_SERVER;
+ Package msg = MessageUtils.buildPackage(eventMeshMessage, command);
+ Assert.assertNotNull(msg);
+ Assert.assertEquals(msg.getHeader().getCommand(), command);
+
Assert.assertEquals(msg.getHeader().getProperty(Constants.PROTOCOL_TYPE),
EventMeshCommon.EM_MESSAGE_PROTOCOL_NAME);
+
Assert.assertEquals(msg.getHeader().getProperty(Constants.PROTOCOL_DESC),
"tcp");
+ Assert.assertNotNull(msg.getBody());
+ Assert.assertTrue(msg.getBody() instanceof EventMeshMessage);
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
