Skip to content
Snippets Groups Projects
Commit 984661f3 authored by MIchael Nguyen's avatar MIchael Nguyen
Browse files

update indexer queue.

parent d65d7e4e
No related branches found
No related tags found
1 merge request!6Trusted ibm
package org.opengroup.osdu.indexerqueue.aws.api;
// TODO: rename package
import com.amazonaws.services.sqs.AmazonSQSConfig;
import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.model.*;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opengroup.osdu.core.aws.sqs.SQSBuilder;
import org.opengroup.osdu.core.aws.sqs.AmazonSQSConfig;
import java.util.List;
import java.util.concurrent.ExecutionException;
......@@ -33,7 +32,7 @@ public class IndexerQueue {
log.debug(String.format("Connecting to the SQS Queue: %s", arguments.queueName));
AmazonSQSConfig sqsConfig = new AmazonSQSConfig(arguments.region);
sqsClient = sqsConfig.AmazonSQS();
AmazonSQS sqsClient = sqsConfig.AmazonSQS();
log.debug(String.format("Creating a thread pool with %s threads", arguments.maxIndexThreads));
ThreadPoolExecutor executorPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(arguments.maxIndexThreads);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment