jonyangx commented on code in PR #2917:
URL:
https://github.com/apache/incubator-eventmesh/pull/2917#discussion_r1068859880
##########
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcBootstrap.java:
##########
@@ -30,10 +30,12 @@ public class EventMeshGrpcBootstrap implements
EventMeshBootstrap {
private final Registry registry;
- public EventMeshGrpcBootstrap(ConfigurationWrapper configurationWrapper,
Registry registry) {
+ public EventMeshGrpcBootstrap(Registry registry) {
this.registry = registry;
- this.eventMeshGrpcConfiguration = new
EventMeshGrpcConfiguration(configurationWrapper);
- eventMeshGrpcConfiguration.init();
+
+ ConfigService configService = ConfigService.getInstance();
Review Comment:
@Test
public void testEventMeshTcpBootstrap() {
ConfigService configService = ConfigService.getInstance();
EventMeshTCPConfiguration o =
configService.buildConfigInstance(EventMeshTCPConfiguration.class);
System.out.println(o);
}
output:
EventMeshTCPConfiguration(eventMeshTcpServerPort=10000,
eventMeshTcpIdleAllSeconds=60, eventMeshTcpIdleWriteSeconds=60,
eventMeshTcpIdleReadSeconds=60, eventMeshTcpMsgReqnumPerSecond=15000,
eventMeshTcpClientMaxNum=10000, eventMeshTcpGlobalScheduler=5,
eventMeshTcpTaskHandleExecutorPoolSize=12,
eventMeshTcpMsgDownStreamExecutorPoolSize=12,
eventMeshTcpSessionExpiredInMills=60000,
eventMeshTcpSessionUpstreamBufferSize=100, eventMeshTcpMsgAsyncRetryTimes=3,
eventMeshTcpMsgSyncRetryTimes=1, eventMeshTcpMsgRetrySyncDelayInMills=500,
eventMeshTcpMsgRetryAsyncDelayInMills=500, eventMeshTcpMsgRetryQueueSize=10000,
eventMeshTcpRebalanceIntervalInMills=30000, eventMeshServerAdminPort=10106,
eventMeshTcpSendBackEnabled=true, eventMeshTcpSendBackMaxTimes=3,
eventMeshTcpPushFailIsolateTimeInMills=30000,
gracefulShutdownSleepIntervalInMills=1000,
sleepIntervalInRebalanceRedirectMills=200, eventMeshEventSize=1000,
eventMeshEventBatchSize=10,
gtc=EventMeshTCPConfiguration.TrafficShapingConfig(wr
iteLimit=0, readLimit=10000, checkInterval=1000, maxTime=2000),
ctc=EventMeshTCPConfiguration.TrafficShapingConfig(writeLimit=0,
readLimit=2000, checkInterval=1000, maxTime=10000))
return all default value,but no load from properties file.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
