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 2a155f8e4 Update PubClientImpl.java
new 4c7da367c Merge pull request #3629 from harshithasudhakar/patch-3
2a155f8e4 is described below
commit 2a155f8e4a62996c87109b3b3c66b3bddfea244a
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Wed Apr 5 01:08:42 2023 +0530
Update PubClientImpl.java
I have swapped the actual and expected values in the lines 137-155.
---
.../eventmesh/runtime/client/impl/PubClientImpl.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
index 67670a17c..bf07151fc 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
@@ -134,25 +134,25 @@ public class PubClientImpl extends TCPClient implements
PubClient {
Command cmd = response.getHeader().getCommand();
switch (request.getHeader().getCommand()) {
case RECOMMEND_REQUEST:
- Assert.assertEquals(cmd, Command.RECOMMEND_RESPONSE);
+ Assert.assertEquals(Command.RECOMMEND_RESPONSE, cmd);
break;
case HELLO_REQUEST:
- Assert.assertEquals(cmd, Command.HELLO_RESPONSE);
+ Assert.assertEquals(Command.HELLO_RESPONSE, cmd);
break;
case HEARTBEAT_REQUEST:
- Assert.assertEquals(cmd, Command.HEARTBEAT_RESPONSE);
+ Assert.assertEquals(Command.HEARTBEAT_RESPONSE, cmd);
break;
case CLIENT_GOODBYE_REQUEST:
- Assert.assertEquals(cmd, Command.CLIENT_GOODBYE_RESPONSE);
+ Assert.assertEquals(Command.CLIENT_GOODBYE_RESPONSE, cmd);
break;
case BROADCAST_MESSAGE_TO_SERVER:
- Assert.assertEquals(cmd,
Command.BROADCAST_MESSAGE_TO_SERVER_ACK);
+ Assert.assertEquals(Command.BROADCAST_MESSAGE_TO_SERVER_ACK,
cmd);
break;
case ASYNC_MESSAGE_TO_SERVER:
- Assert.assertEquals(cmd, Command.ASYNC_MESSAGE_TO_SERVER_ACK);
+ Assert.assertEquals(Command.ASYNC_MESSAGE_TO_SERVER_ACK, cmd);
break;
case REQUEST_TO_SERVER:
- Assert.assertEquals(cmd, Command.RESPONSE_TO_CLIENT);
+ Assert.assertEquals(Command.RESPONSE_TO_CLIENT, cmd);
break;
default:
break;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
