This repository was archived by the owner on Dec 13, 2023. It is now read-only.
File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
awssqs-event-queue/src/main/java/com/netflix/conductor/sqs Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 1515import java .util .HashMap ;
1616import java .util .Map ;
1717
18- import com .amazonaws .services .sqs .AmazonSQS ;
19- import com .amazonaws .services .sqs .AmazonSQSClientBuilder ;
2018import org .apache .commons .lang3 .StringUtils ;
2119import org .springframework .boot .autoconfigure .condition .ConditionalOnMissingBean ;
2220import org .springframework .boot .autoconfigure .condition .ConditionalOnProperty ;
3129import com .netflix .conductor .sqs .eventqueue .SQSObservableQueue .Builder ;
3230
3331import com .amazonaws .auth .AWSCredentialsProvider ;
32+ import com .amazonaws .services .sqs .AmazonSQS ;
33+ import com .amazonaws .services .sqs .AmazonSQSClientBuilder ;
3434import rx .Scheduler ;
3535
3636@ Configuration
Original file line number Diff line number Diff line change 1515import java .util .Map ;
1616import java .util .concurrent .ConcurrentHashMap ;
1717
18- import com .amazonaws .services .sqs .AmazonSQS ;
1918import org .springframework .lang .NonNull ;
2019
2120import com .netflix .conductor .core .events .EventQueueProvider ;
2221import com .netflix .conductor .core .events .queue .ObservableQueue ;
2322import com .netflix .conductor .sqs .eventqueue .SQSObservableQueue ;
2423
24+ import com .amazonaws .services .sqs .AmazonSQS ;
2525import rx .Scheduler ;
2626
2727public class SQSEventQueueProvider implements EventQueueProvider {
Original file line number Diff line number Diff line change 2121import java .util .concurrent .TimeUnit ;
2222import java .util .stream .Collectors ;
2323
24- import com .amazonaws .services .sqs .AmazonSQS ;
2524import org .slf4j .Logger ;
2625import org .slf4j .LoggerFactory ;
2726
3635import com .amazonaws .auth .policy .Statement ;
3736import com .amazonaws .auth .policy .Statement .Effect ;
3837import com .amazonaws .auth .policy .actions .SQSActions ;
38+ import com .amazonaws .services .sqs .AmazonSQS ;
3939import com .amazonaws .services .sqs .model .BatchResultErrorEntry ;
4040import com .amazonaws .services .sqs .model .ChangeMessageVisibilityRequest ;
4141import com .amazonaws .services .sqs .model .CreateQueueRequest ;
You can’t perform that action at this time.
0 commit comments