Fix the key used for database crawler workers.
This commit is contained in:
parent
dd7a080e2d
commit
4aba493ee2
|
@ -52,7 +52,7 @@ public class AccountDatabaseCrawlerCache {
|
||||||
}
|
}
|
||||||
|
|
||||||
public boolean claimActiveWork(String workerId, long ttlMs) {
|
public boolean claimActiveWork(String workerId, long ttlMs) {
|
||||||
return "OK".equals(cacheCluster.withWriteCluster(connection -> connection.sync().set(ACCELERATE_KEY, workerId, SetArgs.Builder.nx().px(ttlMs))));
|
return "OK".equals(cacheCluster.withWriteCluster(connection -> connection.sync().set(ACTIVE_WORKER_KEY, workerId, SetArgs.Builder.nx().px(ttlMs))));
|
||||||
}
|
}
|
||||||
|
|
||||||
public void releaseActiveWork(String workerId) {
|
public void releaseActiveWork(String workerId) {
|
||||||
|
|
Loading…
Reference in New Issue