format code
This commit is contained in:
parent
4b4c1b167e
commit
8acce1c5e2
@ -46,7 +46,7 @@ public class CommunicationController {
|
|||||||
|
|
||||||
private final LongPollingService longPollingService;
|
private final LongPollingService longPollingService;
|
||||||
|
|
||||||
private String trueStr = "true";
|
private static final String TRUE = "true";
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
public CommunicationController(DumpService dumpService, LongPollingService longPollingService) {
|
public CommunicationController(DumpService dumpService, LongPollingService longPollingService) {
|
||||||
@ -70,7 +70,7 @@ public class CommunicationController {
|
|||||||
long lastModifiedTs = StringUtils.isEmpty(lastModified) ? -1 : Long.parseLong(lastModified);
|
long lastModifiedTs = StringUtils.isEmpty(lastModified) ? -1 : Long.parseLong(lastModified);
|
||||||
String handleIp = request.getHeader(NotifyService.NOTIFY_HEADER_OP_HANDLE_IP);
|
String handleIp = request.getHeader(NotifyService.NOTIFY_HEADER_OP_HANDLE_IP);
|
||||||
String isBetaStr = request.getHeader("isBeta");
|
String isBetaStr = request.getHeader("isBeta");
|
||||||
if (StringUtils.isNotBlank(isBetaStr) && trueStr.equals(isBetaStr)) {
|
if (StringUtils.isNotBlank(isBetaStr) && TRUE.equals(isBetaStr)) {
|
||||||
dumpService.dump(dataId, group, tenant, lastModifiedTs, handleIp, true);
|
dumpService.dump(dataId, group, tenant, lastModifiedTs, handleIp, true);
|
||||||
} else {
|
} else {
|
||||||
dumpService.dump(dataId, group, tenant, tag, lastModifiedTs, handleIp);
|
dumpService.dump(dataId, group, tenant, tag, lastModifiedTs, handleIp);
|
||||||
|
@ -24,8 +24,8 @@ import java.util.concurrent.atomic.AtomicLong;
|
|||||||
* @author Nacos
|
* @author Nacos
|
||||||
*/
|
*/
|
||||||
public class ResponseMonitor {
|
public class ResponseMonitor {
|
||||||
static AtomicLong[] getConfigCountDetail = new AtomicLong[8];
|
private static AtomicLong[] getConfigCountDetail = new AtomicLong[8];
|
||||||
static AtomicLong getConfigCount = new AtomicLong();
|
private static AtomicLong getConfigCount = new AtomicLong();
|
||||||
private static final int MS_50 = 50;
|
private static final int MS_50 = 50;
|
||||||
private static final int MS_100 = 100;
|
private static final int MS_100 = 100;
|
||||||
private static final int MS_200 = 200;
|
private static final int MS_200 = 200;
|
||||||
|
@ -69,7 +69,7 @@ public class MD5Util {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static public String compareMd5ResultString(List<String> changedGroupKeys) throws IOException {
|
static public String compareMd5ResultString(List<String> changedGroupKeys) throws IOException {
|
||||||
if (null == changedGroupKeys) {
|
if (null == changedGroupKeys || changedGroupKeys.isEmpty()) {
|
||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -74,7 +74,7 @@ public class ServerListManager {
|
|||||||
GlobalExecutor.registerServerStatusReporter(new ServerStatusReporter(), 5000);
|
GlobalExecutor.registerServerStatusReporter(new ServerStatusReporter(), 5000);
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<Server> refreshServerList() {
|
private List<Server> refreshServerList() {
|
||||||
|
|
||||||
List<Server> result = new ArrayList<>();
|
List<Server> result = new ArrayList<>();
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user