import com.datastax.driver.core.Statement;
public class LastNotified {
- private Map<String,Date> lastNotified = new TreeMap<>();
+ private Map<String,Date> lastNotifiedVar = new TreeMap<>();
private Session session;
public static final Date NEVER = new Date(0);
private static final String SELECT = "SELECT user,target,key,last FROM authz.notified";
query.append('\'');
if(cnt>=30) {
endQuery(query);
- add(session.execute(query.toString()),lastNotified, (x,y) -> false);
+ add(session.execute(query.toString()),lastNotifiedVar, (x,y) -> false);
query.setLength(0);
startQuery(query);
cnt=0;
}
if(cnt>0) {
endQuery(query);
- add(session.execute(query.toString()),lastNotified, (x,y) -> false);
+ add(session.execute(query.toString()),lastNotifiedVar, (x,y) -> false);
}
}
}
public Date lastNotified(String key) {
- Date d = lastNotified.get(key);
+ Date d = lastNotifiedVar.get(key);
return d==null?NEVER:d;
}
try {
Statement stmt = new SimpleStatement( SELECT );
results = session.execute(stmt);
- add(results,lastNotified, (fullKey, last) -> {
+ add(results,lastNotifiedVar, (fullKey, last) -> {
if(delRange.inRange(last)) {
String[] params = Split.splitTrim('|', fullKey,3);
if(params.length==3) {