Major version bump

Author: robin-aws

pom.xml

@@ -2,7 +2,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.amazonaws</groupId>
   <artifactId>amazon-sqs-java-temporary-queues-client-samples</artifactId>
-  <version>0.9.0</version>
+  <version>1.0.0</version>
   <scm>
      <url>https://github.com/aws-samples/amazon-sqs-java-temporary-queues-client-samples.git</url>
   </scm>
@@ -43,7 +43,7 @@
     <dependency>
       <groupId>com.amazonaws</groupId>
       <artifactId>amazon-sqs-java-temporary-queues-client</artifactId>
-      <version>0.9.0</version>
+      <version>1.0.0</version>
     </dependency>
     <dependency>
       <groupId>com.amazonaws</groupId>

src/main/java/com/amazonaws/services/sqs/WidgetSupplier.java

@@ -4,6 +4,7 @@
 
 import com.amazonaws.regions.Regions;
 import com.amazonaws.services.sqs.util.SQSMessageConsumer;
+import com.amazonaws.services.sqs.util.SQSMessageConsumerBuilder;
 
 public class WidgetSupplier {
 
@@ -17,14 +18,17 @@ public static void main(String[] args) throws Exception {
 		AmazonSQSResponder responder = AmazonSQSResponderClientBuilder.standard()
 		        .withAmazonSQS(sqs)
                 .build();
-		
-		SQSMessageConsumer consumer = new SQSMessageConsumer(responder.getAmazonSQS(), queueUrl, message -> {
-			int x = ThreadLocalRandom.current().nextInt(10) + 1;
-			String responseBody = "Here are " + x + " more widgets. Enjoy!";
-			System.out.println("Sending reply: " + responseBody);
-			responder.sendResponseMessage(MessageContent.fromMessage(message),
-					                      new MessageContent(responseBody));
-		});
+
+		SQSMessageConsumer consumer = SQSMessageConsumerBuilder.standard()
+				.withAmazonSQS(responder.getAmazonSQS())
+				.withQueueUrl(queueUrl)
+				.withConsumer(message -> {
+					int x = ThreadLocalRandom.current().nextInt(10) + 1;
+					String responseBody = "Here are " + x + " more widgets. Enjoy!";
+					System.out.println("Sending reply: " + responseBody);
+					responder.sendResponseMessage(MessageContent.fromMessage(message),
+							                      new MessageContent(responseBody));
+				}).build();
 		consumer.start();
 
 		while (running) {};

src/main/java/com/lu/util/concurrent/sqs/SQSOrderExecutorServer.java

@@ -16,6 +16,7 @@
 import com.amazonaws.services.sqs.MessageContent;
 import com.amazonaws.services.sqs.model.Message;
 import com.amazonaws.services.sqs.util.SQSMessageConsumer;
+import com.amazonaws.services.sqs.util.SQSMessageConsumerBuilder;
 import com.lu.order.Order;
 import com.lu.util.concurrent.CannotExecuteOrderException;
 import com.lu.util.concurrent.OrderExecuter;
@@ -32,7 +33,11 @@ public class SQSOrderExecutorServer implements Consumer<Message> {
 
 	public SQSOrderExecutorServer(AmazonSQSResponder responseClient, String requestQueueUrl) {
 		this.responseClient = responseClient;
-        this.consumer = new SQSMessageConsumer(responseClient.getAmazonSQS(), requestQueueUrl, this);
+		this.consumer = SQSMessageConsumerBuilder.standard()
+				.withAmazonSQS(responseClient.getAmazonSQS())
+				.withQueueUrl(requestQueueUrl)
+				.withConsumer(this)
+				.build();
 		this.executer = new OrderExecuter();
 	}