Skip to content

Commit c2eb997

Browse files
committed
[fit] 修改代码格式错误,增加this.
1 parent 45f8688 commit c2eb997

File tree

1 file changed

+9
-9
lines changed
  • framework/fit/java/fit-builtin/plugins/fit-service-coordination-nacos/src/main/java/modelengine/fit/service/server

1 file changed

+9
-9
lines changed

framework/fit/java/fit-builtin/plugins/fit-service-coordination-nacos/src/main/java/modelengine/fit/service/server/NacosRegistryServer.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ public void registerFitables(List<FitableMeta> fitableMetas, Worker worker, Appl
126126
application.getNameVersion());
127127
for (FitableMeta meta : fitableMetas) {
128128
FitableInfo fitable = meta.getFitable();
129-
String groupName = getGroupName(fitable);
130-
String serviceName = getServiceName(fitable);
129+
String groupName = this.getGroupName(fitable);
130+
String serviceName = this.getServiceName(fitable);
131131
List<Instance> instances = createInstance(worker, application, meta);
132132
for (Instance instance : instances) {
133133
this.namingService.registerInstance(serviceName, groupName, instance);
@@ -312,8 +312,8 @@ private Map<Application, List<Instance>> groupInstancesByApplication(List<Instan
312312
}
313313

314314
private List<Instance> queryInstances(FitableInfo fitable) throws NacosException {
315-
String groupName = getGroupName(fitable);
316-
String serviceName = getServiceName(fitable);
315+
String groupName = this.getGroupName(fitable);
316+
String serviceName = this.getServiceName(fitable);
317317
return this.namingService.selectInstances(serviceName, groupName, true);
318318
}
319319

@@ -391,8 +391,8 @@ public List<FitableAddressInstance> subscribeFitables(List<FitableInfo> fitables
391391
callbackFitableId);
392392
for (FitableInfo fitable : fitables) {
393393
try {
394-
String groupName = getGroupName(fitable);
395-
String serviceName = getServiceName(fitable);
394+
String groupName = this.getGroupName(fitable);
395+
String serviceName = this.getServiceName(fitable);
396396
if (this.serviceSubscriptions.containsKey(buildServiceKey(groupName, serviceName))) {
397397
log.debug("Already subscribed to service. [groupName={}, serviceName={}]", groupName, serviceName);
398398
continue;
@@ -421,8 +421,8 @@ public void unsubscribeFitables(List<FitableInfo> fitables, String workerId, Str
421421
callbackFitableId);
422422
for (FitableInfo fitable : fitables) {
423423
try {
424-
String groupName = getGroupName(fitable);
425-
String serviceName = getServiceName(fitable);
424+
String groupName = this.getGroupName(fitable);
425+
String serviceName = this.getServiceName(fitable);
426426
EventListener listener = this.serviceSubscriptions.get(buildServiceKey(groupName, serviceName));
427427
this.namingService.unsubscribe(serviceName, groupName, listener);
428428
this.serviceSubscriptions.remove(buildServiceKey(groupName, serviceName));
@@ -458,7 +458,7 @@ public List<FitableMetaInstance> queryFitableMetas(List<GenericableInfo> generic
458458

459459
private void processGenericableServices(GenericableInfo genericable,
460460
Map<FitableMeta, Set<String>> metaEnvironments) {
461-
String groupName = getGroupName(genericable);
461+
String groupName = this.getGroupName(genericable);
462462
try {
463463
ListView<String> services = this.namingService.getServicesOfServer(1, Integer.MAX_VALUE, groupName);
464464
for (String serviceName : services.getData()) {

0 commit comments

Comments
 (0)