Revert "updating fork with master repo" (#2)

This reverts commit bec50bd.

Author: pranav8494

NOTICE.txt

@@ -1,5 +1,5 @@
 Amazon SQS Java Messaging Library
-Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+Copyright 2010-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 
 This product includes software developed by
 Amazon Technologies, Inc (http://www.amazon.com/).

README.md

@@ -6,22 +6,23 @@ for communicating with Amazon Simple Queue Service. This project builds on top o
 * You can download release builds through the [releases section of this](https://github.com/awslabs/amazon-sqs-java-messaging-lib) project.
 * For more information on using the amazon-sqs-java-messaging-lib, see our getting started guide to SQS [here](http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html).
 
-## Getting Started
+##Getting Started
 
 * **Sign up for AWS** — Before you begin, you need an AWS account. For more information about creating an AWS account and retrieving your AWS credentials, see [AWS Account and Credentials](http://docs.aws.amazon.com/AWSSdkDocsJava/latest/DeveloperGuide/java-dg-setup.html) in the AWS SDK for Java Developer Guide.
-* **Minimum requirements** — To use the sample application, you'll need Java 7 (or later) and [Maven 3](http://maven.apache.org/). For more information about the requirements, see the [Getting Started](http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html) section of the Amazon SQS Developer Guide.
-* **Download** — Download the [latest release](https://github.com/awslabs/amazon-sqs-java-messaging-lib/releases) or pick it up from Maven:
+* **Sign up for Amazon SQS** — Go to the Amazon [SQS console](https://console.aws.amazon.com/sqs/home?region=us-east-1) to sign up for the service.
+* **Minimum requirements** — To use the sample application, you'll need Java 1.7+ and [Maven 3](http://maven.apache.org/). For more information about the requirements, see the [Getting Started](http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html) section of the Amazon SQS Developer Guide.
+* **Download** — Download the [latest preview release](https://github.com/awslabs/amazon-sqs-java-messaging-lib/releases) or pick it up from Maven:
 ```xml
   <dependency>
     <groupId>com.amazonaws</groupId>
     <artifactId>amazon-sqs-java-messaging-lib</artifactId>
-    <version>1.0.4</version>
+    <version>1.0.0</version>
     <type>jar</type>
   </dependency>
 ```
 * **Further information** - Read the [API documentation](http://aws.amazon.com/documentation/sqs/).
 
-## Feedback
+##Feedback
 * Give us feedback [here](https://github.com/awslabs/amazon-sqs-java-messaging-lib/issues).
 * If you'd like to contribute a new feature or bug fix, we'd love to see Github pull requests from you.
 

pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>com.amazonaws</groupId>
   <artifactId>amazon-sqs-java-messaging-lib</artifactId>
-  <version>1.0.4</version>
+  <version>1.0.1</version>
   <packaging>jar</packaging>
   <name>Amazon SQS Java Messaging Library</name>
   <description>The Amazon SQS Java Messaging Library holds the Java Message Service compatible classes, that are used
@@ -38,7 +38,7 @@
   </developers>
 
   <properties>
-    <aws-java-sdk.version>1.11.106</aws-java-sdk.version>
+    <aws-java-sdk.version>1.11.18</aws-java-sdk.version>
   </properties>
 
   <dependencies>

src/main/java/com/amazon/sqs/javamessaging/AmazonSQSMessagingClientWrapper.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * Copyright 2010-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License").
  * You may not use this file except in compliance with the License.
@@ -26,8 +26,6 @@
 
 import com.amazonaws.AmazonClientException;
 import com.amazonaws.AmazonServiceException;
-import com.amazonaws.AmazonWebServiceRequest;
-import com.amazonaws.auth.AWSCredentialsProvider;
 import com.amazonaws.regions.Region;
 import com.amazonaws.services.sqs.AmazonSQS;
 import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequest;
@@ -69,7 +67,6 @@ public class AmazonSQSMessagingClientWrapper {
     }
 
     private final AmazonSQS amazonSQSClient;
-    private final AWSCredentialsProvider credentialsProvider;
 
     /**
      * @param amazonSQSClient
@@ -78,21 +75,10 @@ public class AmazonSQSMessagingClientWrapper {
      *            if the client is null
      */
     public AmazonSQSMessagingClientWrapper(AmazonSQS amazonSQSClient) throws JMSException {
-        this(amazonSQSClient, null);
-    }
-    
-    /**
-     * @param amazonSQSClient
-     *            The AWS SDK Client for SQS.
-     * @throws JMSException
-     *            if the client is null
-     */
-    public AmazonSQSMessagingClientWrapper(AmazonSQS amazonSQSClient, AWSCredentialsProvider credentialsProvider) throws JMSException {
         if (amazonSQSClient == null) {
             throw new JMSException("Amazon SQS client cannot be null");
         }
         this.amazonSQSClient = amazonSQSClient;
-        this.credentialsProvider = credentialsProvider;
     }
 
     /**
@@ -106,15 +92,13 @@ public AmazonSQS getAmazonSQSClient() {
     }
 
     /**
-     * Sets SQS endpoint and wraps IllegalArgumentException. 
-     * Deprecated. Instead of manipulating settings of existing AmazonSQS client, provide correct configuration when creating it through SQSConnectionFactory constructors.
+     * Sets SQS endpoint and wraps IllegalArgumentException.
      * 
      * @param endpoint
      *            The endpoint (ex: "sqs.us-east-1.amazonaws.com") of the region
      *            specific AWS endpoint this client will communicate with.
      * @throws JMSException
      */
-    @Deprecated
     public void setEndpoint(String endpoint) throws JMSException {
         try {
             amazonSQSClient.setEndpoint(endpoint);
@@ -125,16 +109,15 @@ public void setEndpoint(String endpoint) throws JMSException {
     }
 
     /**
-     * Sets SQS region and wraps <code>IllegalArgumentException</code>. 
-     * Deprecated. Instead of manipulating settings of existing AmazonSQS client, provide correct configuration when creating it through SQSConnectionFactory constructors.
+     * Sets SQS region and wraps <code>IllegalArgumentException</code>. This is the recommend
+     * way to set-up the SQS end-points.
      * 
      * @param region
      *            The region this client will communicate with. See
      *            {@link Region#getRegion(com.amazonaws.regions.Regions)} for
      *            accessing a given region.
      * @throws JMSException
      */
-    @Deprecated
     public void setRegion(Region region) throws JMSException {
         try {
             amazonSQSClient.setRegion(region);
@@ -155,7 +138,6 @@ public void setRegion(Region region) throws JMSException {
      */
     public void deleteMessage(DeleteMessageRequest deleteMessageRequest) throws JMSException {
         try {
-            prepareRequest(deleteMessageRequest);
             amazonSQSClient.deleteMessage(deleteMessageRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "deleteMessage");
@@ -178,7 +160,6 @@ public void deleteMessage(DeleteMessageRequest deleteMessageRequest) throws JMSE
      */
     public DeleteMessageBatchResult deleteMessageBatch(DeleteMessageBatchRequest deleteMessageBatchRequest) throws JMSException {
         try {
-            prepareRequest(deleteMessageBatchRequest);
             return amazonSQSClient.deleteMessageBatch(deleteMessageBatchRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "deleteMessageBatch");
@@ -198,7 +179,6 @@ public DeleteMessageBatchResult deleteMessageBatch(DeleteMessageBatchRequest del
      */
     public SendMessageResult sendMessage(SendMessageRequest sendMessageRequest) throws JMSException {
         try {
-            prepareRequest(sendMessageRequest);
             return amazonSQSClient.sendMessage(sendMessageRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "sendMessage");
@@ -217,7 +197,7 @@ public SendMessageResult sendMessage(SendMessageRequest sendMessageRequest) thro
      */
     public boolean queueExists(String queueName) throws JMSException {
         try {
-            amazonSQSClient.getQueueUrl(prepareRequest(new GetQueueUrlRequest(queueName)));
+            amazonSQSClient.getQueueUrl(new GetQueueUrlRequest(queueName));
             return true;
         } catch (QueueDoesNotExistException e) {
             return false;
@@ -243,7 +223,6 @@ public boolean queueExists(String queueName, String queueOwnerAccountId) throws
         try {
             GetQueueUrlRequest getQueueUrlRequest = new GetQueueUrlRequest(queueName);
             getQueueUrlRequest.setQueueOwnerAWSAccountId(queueOwnerAccountId);
-            prepareRequest(getQueueUrlRequest);
             amazonSQSClient.getQueueUrl(getQueueUrlRequest);
             return true;
         } catch (QueueDoesNotExistException e) {
@@ -275,7 +254,9 @@ public GetQueueUrlResult getQueueUrl(String queueName) throws JMSException {
      * @throws JMSException
      */
     public GetQueueUrlResult getQueueUrl(String queueName, String queueOwnerAccountId) throws JMSException {
-        return getQueueUrl(new GetQueueUrlRequest(queueName).withQueueOwnerAWSAccountId(queueOwnerAccountId));
+        GetQueueUrlRequest getQueueUrlRequest = new GetQueueUrlRequest(queueName);
+        getQueueUrlRequest.setQueueOwnerAWSAccountId(queueOwnerAccountId);
+        return getQueueUrl(getQueueUrlRequest);
     }
 
     /**
@@ -290,7 +271,6 @@ public GetQueueUrlResult getQueueUrl(String queueName, String queueOwnerAccountI
      */
     public GetQueueUrlResult getQueueUrl(GetQueueUrlRequest getQueueUrlRequest) throws JMSException {
         try {
-            prepareRequest(getQueueUrlRequest);
             return amazonSQSClient.getQueueUrl(getQueueUrlRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "getQueueUrl");  
@@ -308,7 +288,11 @@ public GetQueueUrlResult getQueueUrl(GetQueueUrlRequest getQueueUrlRequest) thro
      * @throws JMSException
      */
     public CreateQueueResult createQueue(String queueName) throws JMSException {
-        return createQueue(new CreateQueueRequest(queueName));
+        try {
+            return amazonSQSClient.createQueue(queueName);
+        } catch (AmazonClientException e) {
+            throw handleException(e, "createQueue");   
+        }    
     }
 
     /**
@@ -325,7 +309,6 @@ public CreateQueueResult createQueue(String queueName) throws JMSException {
      */
     public CreateQueueResult createQueue(CreateQueueRequest createQueueRequest) throws JMSException {
         try {
-            prepareRequest(createQueueRequest);
             return amazonSQSClient.createQueue(createQueueRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "createQueue");   
@@ -347,7 +330,6 @@ public CreateQueueResult createQueue(CreateQueueRequest createQueueRequest) thro
      */    
     public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageRequest) throws JMSException {
         try {
-            prepareRequest(receiveMessageRequest);
             return amazonSQSClient.receiveMessage(receiveMessageRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "receiveMessage");
@@ -365,7 +347,6 @@ public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageR
      */
     public void changeMessageVisibility(ChangeMessageVisibilityRequest changeMessageVisibilityRequest) throws JMSException {
         try {
-            prepareRequest(changeMessageVisibilityRequest);
             amazonSQSClient.changeMessageVisibility(changeMessageVisibilityRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "changeMessageVisibility");
@@ -387,7 +368,6 @@ public void changeMessageVisibility(ChangeMessageVisibilityRequest changeMessage
     public ChangeMessageVisibilityBatchResult changeMessageVisibilityBatch(ChangeMessageVisibilityBatchRequest changeMessageVisibilityBatchRequest)
             throws JMSException {
         try {
-            prepareRequest(changeMessageVisibilityBatchRequest);
             return amazonSQSClient.changeMessageVisibilityBatch(changeMessageVisibilityBatchRequest);
         } catch (AmazonClientException e) {
             throw handleException(e, "changeMessageVisibilityBatch");
@@ -442,13 +422,4 @@ private JMSException handleException(AmazonClientException e, String operationNa
     private boolean isJMSSecurityException(AmazonServiceException e) {
         return SECURITY_EXCEPTION_ERROR_CODES.contains(e.getErrorCode()) ;
     }
-    
-    private <T extends AmazonWebServiceRequest> T prepareRequest(T request) {
-        request.getRequestClientOptions().appendUserAgent(SQSMessagingClientConstants.APPENDED_USER_AGENT_HEADER_VERSION);
-        if (credentialsProvider != null) {
-            request.setRequestCredentialsProvider(credentialsProvider);
-        }
-        return request;
-    }
-    
 }

src/main/java/com/amazon/sqs/javamessaging/PrefetchManager.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * Copyright 2010-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License").
  * You may not use this file except in compliance with the License.
@@ -27,12 +27,6 @@ public interface PrefetchManager {
      */
     public void messageDispatched();
 
-    /**
-     * Notify the prefetchThread that the message listener has finished with any
-     * previous message and is ready to accept another.
-     */
-    public void messageListenerReady();
-    
     /**
      * This is used to determine the state of the consumer, when the message
      * listener scheduler is processing the messages.

src/main/java/com/amazon/sqs/javamessaging/ProviderConfiguration.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * Copyright 2010-2014 Amazon.com, Inc. or its affiliates. All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License").
  * You may not use this file except in compliance with the License.
@@ -18,8 +18,11 @@
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
+
 import javax.jms.IllegalStateException;
+
 import javax.jms.Connection;
+
 import javax.jms.ConnectionConsumer;
 import javax.jms.ConnectionMetaData;
 import javax.jms.Destination;
@@ -90,8 +93,7 @@ public class SQSConnection implements Connection, QueueConnection {
 
     /**
      * Configures the amount of messages that can be prefetched by a consumer. A
-     * single consumer cannot prefetch more than 10 messages in a single call to SQS,
-     * but it will make multiple calls as necessary.
+     * single consumer cannot prefetch more than 10 messages.
      */
     private final int numberOfMessagesToPrefetch;
     private volatile boolean closed = false;