refs #154: Fix builds

JaidenAshmore · Jun 17, 2020 · 73f6f93 · 73f6f93
1 parent c61421a
commit 73f6f93
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 13 deletions.
diff --git a/examples/spring-integration-test-example/pom.xml b/examples/spring-integration-test-example/pom.xml
@@ -66,13 +66,6 @@
             <scope>test</scope>
         </dependency>
 
-        <dependency>
-            <groupId>com.jashmore</groupId>
-            <artifactId>local-sqs-test-utils</artifactId>
-            <version>${project.version}</version>
-            <scope>test</scope>
-        </dependency>
-
         <dependency>
             <groupId>com.jashmore</groupId>
             <artifactId>elasticmq-sqs-client</artifactId>

diff --git a/examples/spring-starter-examples/src/main/java/com/jashmore/sqs/examples/Application.java b/examples/spring-starter-examples/src/main/java/com/jashmore/sqs/examples/Application.java
@@ -4,7 +4,7 @@
 import com.jashmore.sqs.spring.config.QueueListenerConfiguration;
 import com.jashmore.sqs.spring.container.basic.QueueListener;
 import com.jashmore.sqs.spring.container.prefetch.PrefetchingQueueListener;
-import com.jashmore.sqs.util.LocalSqsAsyncClient;
+import com.jashmore.sqs.util.LocalSqsAsyncClientImpl;
 import com.jashmore.sqs.util.SqsQueuesConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.elasticmq.rest.sqs.SQSRestServer;
@@ -49,7 +49,7 @@ public SqsAsyncClient sqsAsyncClient() {
                 .start();
 
         final Http.ServerBinding serverBinding = sqsRestServer.waitUntilStarted();
-        return new LocalSqsAsyncClient(SqsQueuesConfig
+        return new LocalSqsAsyncClientImpl(SqsQueuesConfig
                 .builder()
                 .sqsServerUrl("http://localhost:" + serverBinding.localAddress().getPort())
                 .queue(SqsQueuesConfig.QueueConfig.builder().queueName("test").build())

diff --git a/...library-comparison/src/main/java/com/jashmore/sqs/examples/SqsListenersConfiguration.java b/...library-comparison/src/main/java/com/jashmore/sqs/examples/SqsListenersConfiguration.java
@@ -21,6 +21,7 @@
 import com.jashmore.sqs.examples.latency.LatencyAppliedAmazonSqsAsync;
 import com.jashmore.sqs.examples.latency.LatencyAppliedSqsAsyncClient;
 import com.jashmore.sqs.util.LocalSqsAsyncClient;
+import com.jashmore.sqs.util.LocalSqsAsyncClientImpl;
 import com.jashmore.sqs.util.SqsQueuesConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.elasticmq.rest.sqs.SQSRestServer;
@@ -77,7 +78,7 @@ public SQSRestServer sqsRestServer() {
     @Bean
     public SqsAsyncClient sqsAsyncClient(SQSRestServer sqsRestServer) throws Exception {
         final Http.ServerBinding serverBinding = sqsRestServer.waitUntilStarted();
-        final LocalSqsAsyncClient localSqsAsyncClient = new LocalSqsAsyncClient(SqsQueuesConfig
+        final LocalSqsAsyncClient localSqsAsyncClient = new LocalSqsAsyncClientImpl(SqsQueuesConfig
                 .builder()
                 .sqsServerUrl("http://localhost:" + serverBinding.localAddress().getPort())
                 .queue(SqsQueuesConfig.QueueConfig.builder().queueName(JMS_10_QUEUE_NAME).build())
@@ -89,8 +90,6 @@ public SqsAsyncClient sqsAsyncClient(SQSRestServer sqsRestServer) throws Excepti
                 .queue(SqsQueuesConfig.QueueConfig.builder().queueName(QUEUE_LISTENER_30_QUEUE_NAME).build())
                 .build());
 
-        localSqsAsyncClient.buildQueues();
-
         sendMessagesToQueue(localSqsAsyncClient);
 
         return new LatencyAppliedSqsAsyncClient(localSqsAsyncClient);
@@ -104,7 +103,7 @@ public SqsAsyncClient sqsAsyncClient(SQSRestServer sqsRestServer) throws Excepti
      * @return client for communicating with the local SQS
      */
     @Bean
-    public AmazonSQSAsync amazonSqs(SQSRestServer sqsRestServer, SqsAsyncClient ignored) {
+    public AmazonSQSAsync amazonSqs(SQSRestServer sqsRestServer, @SuppressWarnings("unused") SqsAsyncClient ignored) {
         final Http.ServerBinding serverBinding = sqsRestServer.waitUntilStarted();
 
         return new LatencyAppliedAmazonSqsAsync(AmazonSQSAsyncClientBuilder.standard()