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

updating indexer.

parent 0d95c005
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.AmazonSQS;
import com.amazonaws.services.sqs.model.*;
import org.apache.commons.cli.ParseException;
import org.apache.commons.collections4.ListUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opengroup.osdu.core.aws.sqs.SQSBuilder;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class IndexerQueue {
/**
......@@ -31,13 +23,10 @@ public class IndexerQueue {
* @throws InterruptedException
*/
// TODO: what happens when the exception happens here?
public static void main(String[] args) throws ExecutionException, InterruptedException, ParseException {
public static void main(String[] args) {
Logger log = LogManager.getLogger(IndexerQueue.class);
try {
log.debug("Starting Indexer Queue and obtaining Arguments");
Arguments arguments = new Arguments();
......
......@@ -15,7 +15,8 @@ import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Component;
import javax.inject.Inject;
// TODO: Elastic Client Handler should be designed to allow cloud providers to implement their own handler if not we have to inherited
// SPI needs to be refactored
@Primary
@Component
public class ElasticClientHandlerAws extends ElasticClientHandler {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment