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 2d2bac23c ISSUE #3507]Swap these 2 arguments so they are in the
correct order: expected value, actual value.[ClientConfigurationTest]
2d2bac23c is described below
commit 2d2bac23c587b5d4636bbe58d5696a2692fefde5
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Mon Apr 24 13:45:36 2023 +0530
ISSUE #3507]Swap these 2 arguments so they are in the correct order:
expected value, actual value.[ClientConfigurationTest]
---
.../rocketmq/config/ClientConfigurationTest.java | 32 +++++++++++-----------
1 file changed, 16 insertions(+), 16 deletions(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfigurationTest.java
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfigurationTest.java
index c8b3dbe2a..3088db355 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfigurationTest.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfigurationTest.java
@@ -43,21 +43,21 @@ public class ClientConfigurationTest {
}
private void assertConfig(ClientConfiguration config) {
- Assert.assertEquals(config.getNamesrvAddr(),
"127.0.0.1:9876;127.0.0.1:9876");
- Assert.assertEquals(config.getClientUserName(), "username-succeed!!!");
- Assert.assertEquals(config.getClientPass(), "password-succeed!!!");
- Assert.assertEquals(config.getConsumeThreadMin(),
Integer.valueOf(1816));
- Assert.assertEquals(config.getConsumeThreadMax(),
Integer.valueOf(2816));
- Assert.assertEquals(config.getConsumeQueueSize(),
Integer.valueOf(3816));
- Assert.assertEquals(config.getPullBatchSize(), Integer.valueOf(4816));
- Assert.assertEquals(config.getAckWindow(), Integer.valueOf(5816));
- Assert.assertEquals(config.getPubWindow(), Integer.valueOf(6816));
- Assert.assertEquals(config.getConsumeTimeout(), 7816);
- Assert.assertEquals(config.getPollNameServerInterval(),
Integer.valueOf(8816));
- Assert.assertEquals(config.getHeartbeatBrokerInterval(),
Integer.valueOf(9816));
- Assert.assertEquals(config.getRebalanceInterval(),
Integer.valueOf(11816));
- Assert.assertEquals(config.getClusterName(), "cluster-succeed!!!");
- Assert.assertEquals(config.getAccessKey(), "accessKey-succeed!!!");
- Assert.assertEquals(config.getSecretKey(), "secretKey-succeed!!!");
+ Assert.assertEquals("127.0.0.1:9876;127.0.0.1:9876",
config.getNamesrvAddr());
+ Assert.assertEquals("username-succeed!!!", config.getClientUserName());
+ Assert.assertEquals("password-succeed!!!", config.getClientPass());
+ Assert.assertEquals(Integer.valueOf(1816),
config.getConsumeThreadMin());
+ Assert.assertEquals(Integer.valueOf(2816),
config.getConsumeThreadMax());
+ Assert.assertEquals(Integer.valueOf(3816),
config.getConsumeQueueSize());
+ Assert.assertEquals(Integer.valueOf(4816), config.getPullBatchSize());
+ Assert.assertEquals(Integer.valueOf(5816), config.getAckWindow());
+ Assert.assertEquals(Integer.valueOf(6816), config.getPubWindow());
+ Assert.assertEquals(7816, config.getConsumeTimeout());
+ Assert.assertEquals(Integer.valueOf(8816),
config.getPollNameServerInterval());
+ Assert.assertEquals(Integer.valueOf(9816),
config.getHeartbeatBrokerInterval());
+ Assert.assertEquals(Integer.valueOf(11816),
config.getRebalanceInterval());
+ Assert.assertEquals("cluster-succeed!!!", config.getClusterName());
+ Assert.assertEquals("accessKey-succeed!!!", config.getAccessKey());
+ Assert.assertEquals("secretKey-succeed!!!", config.getSecretKey());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
