zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[ISSUE #10310] Update log output in RpcConfigChangeNotifier.java when push fail (#10312)

Browse Source 
* [ISSUE #10310]Update log output in RpcConfigChangeNotifier.java when push fail

Update log output in RpcConfigChangeNotifier.java when push fail

* update indentation level

update indentation level
This commit is contained in:
MajorHe1 2023-04-13 19:14:45 +08:00 committed by GitHub
parent 916534ecfc
commit fb8255c8b7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
config/src/main/java/com/alibaba/nacos/config/server/remote/RpcConfigChangeNotifier.java
View File

@ -117,7 +117,7 @@ public class RpcConfigChangeNotifier extends Subscriber<LocalDataChangeEvent> {
push(rpcPushRetryTask);
notifyClientCount++;
}
Loggers.REMOTE_PUSH.info("push [{}] clients ,groupKey=[{}]", notifyClientCount, groupKey);
Loggers.REMOTE_PUSH.info("push [{}] clients, groupKey=[{}]", notifyClientCount, groupKey);
}
@Override
@ -191,7 +191,9 @@ public class RpcConfigChangeNotifier extends Subscriber<LocalDataChangeEvent> {
tpsCheckRequest.setPointName(POINT_CONFIG_PUSH_FAIL);
tpsControlManager.check(tpsCheckRequest);
Loggers.REMOTE_PUSH.warn("Push fail", e);
Loggers.REMOTE_PUSH
.warn("Push fail, dataId={}, group={}, tenant={}, clientId={}", notifyRequest.getDataId(),
notifyRequest.getGroup(), notifyRequest.getTenant(), connectionId, e);
push(RpcPushTask.this);
}
@ -206,7 +208,7 @@ public class RpcConfigChangeNotifier extends Subscriber<LocalDataChangeEvent> {
ConfigChangeNotifyRequest notifyRequest = retryTask.notifyRequest;
if (retryTask.isOverTimes()) {
Loggers.REMOTE_PUSH
.warn("push callback retry fail over times .dataId={},group={},tenant={},clientId={},will unregister client.",
.warn("push callback retry fail over times. dataId={},group={},tenant={},clientId={}, will unregister client.",
notifyRequest.getDataId(), notifyRequest.getGroup(), notifyRequest.getTenant(),
retryTask.connectionId);
connectionManager.unregister(retryTask.connectionId);