public static void main()

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);
            }
            
        }
    }