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 f623aa771 Update EventMeshTCPConfigurationTest.java
new d92a517d9 Merge pull request #3642 from harshithasudhakar/patch-12
f623aa771 is described below
commit f623aa771696c4111bc3a2c21d2296f1fe2e48b6
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Fri Apr 7 00:24:31 2023 +0530
Update EventMeshTCPConfigurationTest.java
Swapped actual and expected values.
---
.../EventMeshTCPConfigurationTest.java | 50 +++++++++++-----------
1 file changed, 25 insertions(+), 25 deletions(-)
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfigurationTest.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfigurationTest.java
index fa8ce064a..71a7ea19a 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfigurationTest.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfigurationTest.java
@@ -41,31 +41,31 @@ public class EventMeshTCPConfigurationTest {
}
private void assertTCPConfig(EventMeshTCPConfiguration config) {
- Assert.assertEquals(config.getEventMeshTcpServerPort(), 816);
- Assert.assertEquals(config.getEventMeshTcpIdleAllSeconds(), 1816);
- Assert.assertEquals(config.getEventMeshTcpIdleWriteSeconds(), 2816);
- Assert.assertEquals(config.getEventMeshTcpIdleReadSeconds(), 3816);
- Assert.assertEquals(config.getEventMeshTcpMsgReqnumPerSecond(),
Integer.valueOf(4816));
- Assert.assertEquals(config.getEventMeshTcpClientMaxNum(), 5816);
- Assert.assertEquals(config.getEventMeshTcpGlobalScheduler(), 6816);
-
Assert.assertEquals(config.getEventMeshTcpTaskHandleExecutorPoolSize(), 7816);
-
Assert.assertEquals(config.getEventMeshTcpMsgDownStreamExecutorPoolSize(),
8816);
- Assert.assertEquals(config.getEventMeshTcpSessionExpiredInMills(),
1816);
- Assert.assertEquals(config.getEventMeshTcpSessionUpstreamBufferSize(),
11816);
- Assert.assertEquals(config.getEventMeshTcpMsgAsyncRetryTimes(), 12816);
- Assert.assertEquals(config.getEventMeshTcpMsgSyncRetryTimes(), 13816);
- Assert.assertEquals(config.getEventMeshTcpMsgRetrySyncDelayInMills(),
14816);
- Assert.assertEquals(config.getEventMeshTcpMsgRetryAsyncDelayInMills(),
15816);
- Assert.assertEquals(config.getEventMeshTcpMsgRetryQueueSize(), 16816);
- Assert.assertEquals(config.getEventMeshTcpRebalanceIntervalInMills(),
Integer.valueOf(17816));
- Assert.assertEquals(config.getEventMeshServerAdminPort(), 18816);
- Assert.assertEquals(config.isEventMeshTcpSendBackEnabled(),
Boolean.TRUE);
- Assert.assertEquals(config.getEventMeshTcpSendBackMaxTimes(), 3);
-
Assert.assertEquals(config.getEventMeshTcpPushFailIsolateTimeInMills(), 21816);
- Assert.assertEquals(config.getGracefulShutdownSleepIntervalInMills(),
22816);
- Assert.assertEquals(config.getSleepIntervalInRebalanceRedirectMills(),
23816);
- Assert.assertEquals(config.getEventMeshEventSize(), 22816);
- Assert.assertEquals(config.getEventMeshEventBatchSize(), 23816);
+ Assert.assertEquals(816, config.getEventMeshTcpServerPort());
+ Assert.assertEquals(1816, config.getEventMeshTcpIdleAllSeconds());
+ Assert.assertEquals(2816, config.getEventMeshTcpIdleWriteSeconds());
+ Assert.assertEquals(3816, config.getEventMeshTcpIdleReadSeconds());
+ Assert.assertEquals(Integer.valueOf(4816),
config.getEventMeshTcpMsgReqnumPerSecond());
+ Assert.assertEquals(5816, config.getEventMeshTcpClientMaxNum());
+ Assert.assertEquals(6816, config.getEventMeshTcpGlobalScheduler());
+ Assert.assertEquals(7816,
config.getEventMeshTcpTaskHandleExecutorPoolSize());
+ Assert.assertEquals(8816,
config.getEventMeshTcpMsgDownStreamExecutorPoolSize());
+ Assert.assertEquals(1816,
config.getEventMeshTcpSessionExpiredInMills());
+ Assert.assertEquals(11816,
config.getEventMeshTcpSessionUpstreamBufferSize());
+ Assert.assertEquals(12816, config.getEventMeshTcpMsgAsyncRetryTimes());
+ Assert.assertEquals(13816, config.getEventMeshTcpMsgSyncRetryTimes());
+ Assert.assertEquals(14816,
config.getEventMeshTcpMsgRetrySyncDelayInMills());
+ Assert.assertEquals(15816,
config.getEventMeshTcpMsgRetryAsyncDelayInMills());
+ Assert.assertEquals(16816, config.getEventMeshTcpMsgRetryQueueSize());
+ Assert.assertEquals(Integer.valueOf(17816),
config.getEventMeshTcpRebalanceIntervalInMills());
+ Assert.assertEquals(18816, config.getEventMeshServerAdminPort());
+ Assert.assertEquals(Boolean.TRUE,
config.isEventMeshTcpSendBackEnabled());
+ Assert.assertEquals(3, config.getEventMeshTcpSendBackMaxTimes());
+ Assert.assertEquals(21816,
config.getEventMeshTcpPushFailIsolateTimeInMills());
+ Assert.assertEquals(22816,
config.getGracefulShutdownSleepIntervalInMills());
+ Assert.assertEquals(23816,
config.getSleepIntervalInRebalanceRedirectMills());
+ Assert.assertEquals(22816, config.getEventMeshEventSize());
+ Assert.assertEquals(23816, config.getEventMeshEventBatchSize());
}
private void assertCommonConfig(CommonConfiguration config) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
