@@ -45,7 +45,7 @@ public class EventMeshServer {
45
45
46
46
private EventMeshHTTPConfiguration eventMeshHttpConfiguration ;
47
47
48
- private EventMeshTCPConfiguration eventMeshTCPConfiguration ;
48
+ private EventMeshTCPConfiguration eventMeshTcpConfiguration ;
49
49
50
50
private Acl acl ;
51
51
@@ -58,17 +58,17 @@ public class EventMeshServer {
58
58
private ServiceState serviceState ;
59
59
60
60
public EventMeshServer (EventMeshHTTPConfiguration eventMeshHttpConfiguration ,
61
- EventMeshTCPConfiguration eventMeshTCPConfiguration ,
61
+ EventMeshTCPConfiguration eventMeshTcpConfiguration ,
62
62
EventMeshGrpcConfiguration eventMeshGrpcConfiguration ) {
63
63
this .eventMeshHttpConfiguration = eventMeshHttpConfiguration ;
64
- this .eventMeshTCPConfiguration = eventMeshTCPConfiguration ;
64
+ this .eventMeshTcpConfiguration = eventMeshTcpConfiguration ;
65
65
this .eventMeshGrpcConfiguration = eventMeshGrpcConfiguration ;
66
66
this .acl = new Acl ();
67
67
this .registry = new Registry ();
68
68
this .trace = new Trace (eventMeshHttpConfiguration .eventMeshServerTraceEnable );
69
69
this .connectorResource = new ConnectorResource ();
70
70
71
- ConfigurationContextUtil .putIfAbsent (ConfigurationContextUtil .TCP , eventMeshTCPConfiguration );
71
+ ConfigurationContextUtil .putIfAbsent (ConfigurationContextUtil .TCP , eventMeshTcpConfiguration );
72
72
ConfigurationContextUtil .putIfAbsent (ConfigurationContextUtil .GRPC , eventMeshGrpcConfiguration );
73
73
ConfigurationContextUtil .putIfAbsent (ConfigurationContextUtil .HTTP , eventMeshHttpConfiguration );
74
74
}
@@ -79,10 +79,10 @@ public void init() throws Exception {
79
79
}
80
80
81
81
// registry init
82
- if (eventMeshTCPConfiguration != null
83
- && eventMeshTCPConfiguration .eventMeshTcpServerEnabled
84
- && eventMeshTCPConfiguration .eventMeshServerRegistryEnable ) {
85
- registry .init (eventMeshTCPConfiguration .eventMeshRegistryPluginType );
82
+ if (eventMeshTcpConfiguration != null
83
+ && eventMeshTcpConfiguration .eventMeshTcpServerEnabled
84
+ && eventMeshTcpConfiguration .eventMeshServerRegistryEnable ) {
85
+ registry .init (eventMeshTcpConfiguration .eventMeshRegistryPluginType );
86
86
}
87
87
88
88
if (eventMeshGrpcConfiguration != null && eventMeshGrpcConfiguration .eventMeshServerRegistryEnable ) {
@@ -110,9 +110,9 @@ public void init() throws Exception {
110
110
eventMeshHTTPServer .init ();
111
111
}
112
112
113
- if (eventMeshTCPConfiguration != null ) {
114
- eventMeshTCPServer = new EventMeshTCPServer (this , eventMeshTCPConfiguration , registry );
115
- if (eventMeshTCPConfiguration .eventMeshTcpServerEnabled ) {
113
+ if (eventMeshTcpConfiguration != null ) {
114
+ eventMeshTCPServer = new EventMeshTCPServer (this , eventMeshTcpConfiguration , registry );
115
+ if (eventMeshTcpConfiguration .eventMeshTcpServerEnabled ) {
116
116
eventMeshTCPServer .init ();
117
117
}
118
118
}
@@ -130,9 +130,9 @@ public void start() throws Exception {
130
130
acl .start ();
131
131
}
132
132
// registry start
133
- if (eventMeshTCPConfiguration != null
134
- && eventMeshTCPConfiguration .eventMeshTcpServerEnabled
135
- && eventMeshTCPConfiguration .eventMeshServerRegistryEnable ) {
133
+ if (eventMeshTcpConfiguration != null
134
+ && eventMeshTcpConfiguration .eventMeshTcpServerEnabled
135
+ && eventMeshTcpConfiguration .eventMeshServerRegistryEnable ) {
136
136
registry .start ();
137
137
}
138
138
if (eventMeshHttpConfiguration != null && eventMeshHttpConfiguration .eventMeshServerRegistryEnable ) {
@@ -149,7 +149,7 @@ public void start() throws Exception {
149
149
if (eventMeshHttpConfiguration != null ) {
150
150
eventMeshHTTPServer .start ();
151
151
}
152
- if (eventMeshTCPConfiguration != null && eventMeshTCPConfiguration .eventMeshTcpServerEnabled ) {
152
+ if (eventMeshTcpConfiguration != null && eventMeshTcpConfiguration .eventMeshTcpServerEnabled ) {
153
153
eventMeshTCPServer .start ();
154
154
}
155
155
serviceState = ServiceState .RUNNING ;
@@ -160,7 +160,7 @@ public void shutdown() throws Exception {
160
160
serviceState = ServiceState .STOPING ;
161
161
logger .info ("server state:{}" , serviceState );
162
162
eventMeshHTTPServer .shutdown ();
163
- if (eventMeshTCPConfiguration != null && eventMeshTCPConfiguration .eventMeshTcpServerEnabled ) {
163
+ if (eventMeshTcpConfiguration != null && eventMeshTcpConfiguration .eventMeshTcpServerEnabled ) {
164
164
eventMeshTCPServer .shutdown ();
165
165
}
166
166
0 commit comments