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/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 8a009d4c2 [ISSUE #3522] swapped expected and actual values in
assertGrpcConfig test method
new 59097c6cf Merge pull request #3534 from PickBas/fix-3522
8a009d4c2 is described below
commit 8a009d4c25dbce20411926f8a8169d696f0f9347
Author: Kirill Saied <[email protected]>
AuthorDate: Mon Mar 27 22:39:20 2023 +0300
[ISSUE #3522] swapped expected and actual values in assertGrpcConfig test
method
---
.../EventMeshGrpcConfigurationTest.java | 46 +++++++++++-----------
1 file changed, 23 insertions(+), 23 deletions(-)
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
index 75afe7d2e..5481309dc 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
@@ -41,29 +41,29 @@ public class EventMeshGrpcConfigurationTest {
}
private void assertGrpcConfig(EventMeshGrpcConfiguration config) {
- Assert.assertEquals(config.getGrpcServerPort(), 816);
- Assert.assertEquals(config.getEventMeshSessionExpiredInMills(), 1816);
- Assert.assertEquals(config.isEventMeshServerBatchMsgBatchEnabled(),
Boolean.FALSE);
- Assert.assertEquals(config.getEventMeshServerBatchMsgThreadNum(),
2816);
- Assert.assertEquals(config.getEventMeshServerSendMsgThreadNum(), 3816);
- Assert.assertEquals(config.getEventMeshServerPushMsgThreadNum(), 4816);
- Assert.assertEquals(config.getEventMeshServerReplyMsgThreadNum(),
5816);
- Assert.assertEquals(config.getEventMeshServerSubscribeMsgThreadNum(),
6816);
- Assert.assertEquals(config.getEventMeshServerRegistryThreadNum(),
7816);
- Assert.assertEquals(config.getEventMeshServerAdminThreadNum(), 8816);
- Assert.assertEquals(config.getEventMeshServerRetryThreadNum(), 9816);
- Assert.assertEquals(config.getEventMeshServerPullRegistryInterval(),
11816);
-
Assert.assertEquals(config.getEventMeshServerAsyncAccumulationThreshold(),
12816);
- Assert.assertEquals(config.getEventMeshServerRetryBlockQueueSize(),
13816);
- Assert.assertEquals(config.getEventMeshServerBatchBlockQueueSize(),
14816);
- Assert.assertEquals(config.getEventMeshServerSendMsgBlockQueueSize(),
15816);
- Assert.assertEquals(config.getEventMeshServerPushMsgBlockQueueSize(),
16816);
-
Assert.assertEquals(config.getEventMeshServerSubscribeMsgBlockQueueSize(),
17816);
- Assert.assertEquals(config.getEventMeshServerBusyCheckInterval(),
18816);
- Assert.assertEquals(config.isEventMeshServerConsumerEnabled(),
Boolean.TRUE);
- Assert.assertEquals(config.isEventMeshServerUseTls(), Boolean.TRUE);
- Assert.assertEquals(config.getEventMeshBatchMsgRequestNumPerSecond(),
21816);
- Assert.assertEquals(config.getEventMeshMsgReqNumPerSecond(), 19816);
+ Assert.assertEquals(816, config.getGrpcServerPort());
+ Assert.assertEquals(1816, config.getEventMeshSessionExpiredInMills());
+ Assert.assertEquals(Boolean.FALSE,
config.isEventMeshServerBatchMsgBatchEnabled());
+ Assert.assertEquals(2816,
config.getEventMeshServerBatchMsgThreadNum());
+ Assert.assertEquals(3816, config.getEventMeshServerSendMsgThreadNum());
+ Assert.assertEquals(4816, config.getEventMeshServerPushMsgThreadNum());
+ Assert.assertEquals(5816,
config.getEventMeshServerReplyMsgThreadNum());
+ Assert.assertEquals(6816,
config.getEventMeshServerSubscribeMsgThreadNum());
+ Assert.assertEquals(7816,
config.getEventMeshServerRegistryThreadNum());
+ Assert.assertEquals(8816, config.getEventMeshServerAdminThreadNum());
+ Assert.assertEquals(9816, config.getEventMeshServerRetryThreadNum());
+ Assert.assertEquals(11816,
config.getEventMeshServerPullRegistryInterval());
+ Assert.assertEquals(12816,
config.getEventMeshServerAsyncAccumulationThreshold());
+ Assert.assertEquals(13816,
config.getEventMeshServerRetryBlockQueueSize());
+ Assert.assertEquals(14816,
config.getEventMeshServerBatchBlockQueueSize());
+ Assert.assertEquals(15816,
config.getEventMeshServerSendMsgBlockQueueSize());
+ Assert.assertEquals(16816,
config.getEventMeshServerPushMsgBlockQueueSize());
+ Assert.assertEquals(17816,
config.getEventMeshServerSubscribeMsgBlockQueueSize());
+ Assert.assertEquals(18816,
config.getEventMeshServerBusyCheckInterval());
+ Assert.assertEquals(Boolean.TRUE,
config.isEventMeshServerConsumerEnabled());
+ Assert.assertEquals(Boolean.TRUE, config.isEventMeshServerUseTls());
+ Assert.assertEquals(21816,
config.getEventMeshBatchMsgRequestNumPerSecond());
+ Assert.assertEquals(19816, config.getEventMeshMsgReqNumPerSecond());
}
private void assertCommonConfig(CommonConfiguration config) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
