public void initalize()

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

• 12 lines of code
• 1 McCabe index (conditional complexity)

    public void initalize(URI uri, Configuration conf) {
        this.conf = conf;
        
        String keyId = conf.get("fs."+uri.getScheme()+".awsAccessKeyId");
        String keySecret = conf.get("fs."+uri.getScheme()+".awsSecretAccessKey");
        
        //An override option for accessing across accounts
        keyId = conf.get("fs."+uri.getScheme()+".override.awsAccessKeyId", keyId);
        keySecret = conf.get("fs."+uri.getScheme()+".override.awsSecretAccessKey", keySecret);
        
        sqs = new AmazonSQSClient(new BasicAWSCredentials(keyId, keySecret));
        
        //SQS Consistency Queue
        consistencyQueue = conf.get("fs"+uri.getScheme()+".alert.sqs.queue", consistencyQueue);
        consistencyQueue = sqs.getQueueUrl(new GetQueueUrlRequest(consistencyQueue)).getQueueUrl();
        
        //SQS Timeout Queue
        timeoutQueue = conf.get("fs"+uri.getScheme()+".timeout.sqs.queue", timeoutQueue);
        timeoutQueue = sqs.getQueueUrl(new GetQueueUrlRequest(timeoutQueue)).getQueueUrl();
    }