public void writeLogs()

in src/main/java/com/netflix/bdp/s3mper/alert/impl/AlertJanitor.java [105:125]

• 16 lines of code
• 4 McCabe index (conditional complexity)

    public void writeLogs(String queue, Path path) throws IOException {
        FileSystem fs = FileSystem.get(path.toUri(), conf);
        DataOutputStream fout = fs.create(path);
        
        do {
            List<Message> messages = pull(queue, batchCount);

            if(messages.isEmpty()) {
                break;
            }
            
            for(Message m : messages) {
                fout.write((m.getBody().replaceAll("[\n|\r]", " ")+"\n").getBytes("UTF8"));
            }

            delete(queue, messages);
        } while(true);
        
        fout.close();
        fs.close();
    }