private void sendSQSConsistencyMessage()

in src/main/java/com/netflix/bdp/s3mper/alert/impl/CloudWatchAlertDispatcher.java [181:216]

• 25 lines of code
• 5 McCabe index (conditional complexity)

    private void sendSQSConsistencyMessage(List<Path> paths, boolean recovered) {
        S3ConsistencyMessage message = new S3ConsistencyMessage();
        
        buildMessage(message);
        
        List<String> pathStrings = new ArrayList<String>();
        boolean truncated = false;
        
        for(Path p : paths) {
            pathStrings.add(p.toUri().toString());
            
            //Truncate if the message payload gets to be too large (i.e. to many missing files)
            if(pathStrings.size() >= pathReportLimit) {
                truncated = true;
                break;
            }
        }
        
        message.setPaths(pathStrings);
        message.setTruncated(truncated);
        
        int missingFiles = paths.size();
        
        if(recovered) {
            missingFiles = 0;
        }
        
        message.setMissingFiles(missingFiles);
        message.setRecovered(recovered);
        
        sendMessage(consistencyQueueUrl, message);
        
        if(!recovered) {
            sendMessage(notificationQueueUrl, message);
        }
    }