Browse Source

【异步数据同步】调整分布式锁的时间参数

master
wangxianzhang 3 years ago
parent
commit
78c296903f
  1. 4
      epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiNatSyncProcessor.java
  2. 4
      epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiResiComparisonSyncProcessor.java
  3. 4
      epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiTripReportSyncProcessor.java
  4. 4
      epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiVaccineSyncProcessor.java

4
epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiNatSyncProcessor.java

@ -51,11 +51,11 @@ public class YanTaiNatSyncProcessor extends AbstractDataSyncJobProcessor {
@Override @Override
protected long getDistributeLockLeaseTime() { protected long getDistributeLockLeaseTime() {
return 60; return 5;
} }
@Override @Override
protected long getDistributeLockWaitTime() { protected long getDistributeLockWaitTime() {
return 60; return 6;
} }
} }

4
epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiResiComparisonSyncProcessor.java

@ -50,11 +50,11 @@ public class YanTaiResiComparisonSyncProcessor extends AbstractDataSyncJobProces
@Override @Override
protected long getDistributeLockLeaseTime() { protected long getDistributeLockLeaseTime() {
return 60; return 5;
} }
@Override @Override
protected long getDistributeLockWaitTime() { protected long getDistributeLockWaitTime() {
return 60; return 6;
} }
} }

4
epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiTripReportSyncProcessor.java

@ -50,11 +50,11 @@ public class YanTaiTripReportSyncProcessor extends AbstractDataSyncJobProcessor
@Override @Override
protected long getDistributeLockLeaseTime() { protected long getDistributeLockLeaseTime() {
return 60; return 5;
} }
@Override @Override
protected long getDistributeLockWaitTime() { protected long getDistributeLockWaitTime() {
return 60; return 6;
} }
} }

4
epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiVaccineSyncProcessor.java

@ -49,11 +49,11 @@ public class YanTaiVaccineSyncProcessor extends AbstractDataSyncJobProcessor {
@Override @Override
protected long getDistributeLockLeaseTime() { protected long getDistributeLockLeaseTime() {
return 60; return 5;
} }
@Override @Override
protected long getDistributeLockWaitTime() { protected long getDistributeLockWaitTime() {
return 60; return 6;
} }
} }

Loading…
Cancel
Save