Skip to content
Snippets Groups Projects
Commit 95728bba authored by Bill Wang's avatar Bill Wang Committed by Sutton
Browse files

use correct indexerQueueTaskBuilder for AWS

Solve DependencyInjection for ReIndexService (previously using IndexerQueueTaskBuilder from Core)
parent 4c6901cd
No related branches found
No related tags found
1 merge request!91AWS Updates
Pipeline #27272 passed
......@@ -14,15 +14,22 @@
package org.opengroup.osdu.indexer.aws;
import org.opengroup.osdu.indexer.util.IndexerQueueTaskBuilder;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.actuate.autoconfigure.security.servlet.ManagementWebSecurityAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.FilterType;
@SpringBootApplication(exclude = { SecurityAutoConfiguration.class, ManagementWebSecurityAutoConfiguration.class })
@ComponentScan({"org.opengroup.osdu"})
@ComponentScan(
basePackages = {"org.opengroup.osdu"},
excludeFilters={
@ComponentScan.Filter(
type=FilterType.ASSIGNABLE_TYPE,
value=IndexerQueueTaskBuilder.class)
})
public class IndexerAwsApplication {
public static void main(String[] args) {
......
......@@ -31,7 +31,7 @@ import org.springframework.stereotype.Component;
import javax.inject.Inject;
import java.util.HashMap;
import java.util.Map;
//
@Primary
@Component
public class IndexerQueueTaskBuilderAws extends IndexerQueueTaskBuilder {
......@@ -70,12 +70,20 @@ public class IndexerQueueTaskBuilderAws extends IndexerQueueTaskBuilder {
@Override
public void createWorkerTask(String payload, DpsHeaders headers) {
createTask(payload, headers);
this.createTask(payload, headers);
}
@Override
public void createWorkerTask(String payload, Long countDownMillis, DpsHeaders headers){
this.createTask(payload, headers);
}
@Override
public void createReIndexTask(String payload,DpsHeaders headers) {
createTask(payload, headers);
this.createTask(payload, headers);
}
@Override
public void createReIndexTask(String payload, Long countDownMillis, DpsHeaders headers){
this.createTask(payload, headers);
}
private void createTask(String payload, DpsHeaders headers) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment