in src/main/java/com/netflix/bdp/s3mper/alert/impl/AlertJanitor.java [168:190]
public static void main(String[] args) throws Exception {
AlertJanitor janitor = new AlertJanitor();
janitor.initalize(new URI("s3n://placeholder"), new Configuration());
if("clearAll".equalsIgnoreCase(args[0])) {
janitor.clearAll(janitor.consistencyQueue);
janitor.clearAll(janitor.timeoutQueue);
}
if("log".equalsIgnoreCase(args[0])) {
String queue = args[1];
Path path = new Path(args[2]);
if("timeout".equals(queue)) {
janitor.writeLogs(janitor.timeoutQueue, path);
}
if("alert".equals(queue)) {
janitor.writeLogs(janitor.consistencyQueue, path);
}
}
}