Merge pull request #86 from dr3s/85-create-attr

Issue 85: only compare attributes if they are sent on request

Author: adamw

project/plugins.sbt

@@ -2,4 +2,6 @@ addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.11.2")
 
 addSbtPlugin("com.gu" % "sbt-teamcity-test-reporting-plugin" % "1.5")
 
+addSbtPlugin("com.typesafe.sbteclipse" % "sbteclipse-plugin" % "5.0.1")
+
 scalacOptions in ThisBuild ++= Seq("-unchecked", "-deprecation")

rest/rest-sqs-testing-amazon-java-sdk/src/test/scala/org/elasticmq/rest/sqs/AmazonJavaSdkTestSuite.scala

@@ -154,7 +154,7 @@ class AmazonJavaSdkTestSuite extends FunSuite with Matchers with BeforeAndAfter
     // Then
     queueVisibilityTimeout(queueUrl) should be (10)
   }
-
+  
   test("should send and receive a simple message") {
     doTestSendAndReceiveMessage("Message 1")
   }
@@ -795,6 +795,18 @@ class AmazonJavaSdkTestSuite extends FunSuite with Matchers with BeforeAndAfter
 
     result.isLeft should be (true)
   }
+  
+  test("should not return an error if creating an existing queue with a non default visibility timeout") {
+    // Given
+    val queueUrl = client.createQueue(new CreateQueueRequest("testQueue1")
+      .withAttributes(Map(defaultVisibilityTimeoutAttribute -> "42"))).getQueueUrl
+
+    // When
+    val queueUrl2 = client.createQueue(new CreateQueueRequest("testQueue1")).getQueueUrl
+    
+
+    queueUrl should equal(queueUrl2)
+  }
 
   test("should purge the queue") {
     // Given

rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/CreateQueueDirectives.scala

@@ -19,11 +19,11 @@ trait CreateQueueDirectives { this: ElasticMQDirectives with QueueURLModule with
         queueNameFromParams(p) { queueName =>
           val attributes = attributeNameAndValuesReader.read(p)
 
-          val secondsVisibilityTimeout = attributes.parseOptionalLong(VisibilityTimeoutParameter)
-            .getOrElse(DefaultVisibilityTimeout)
+          val secondsVisibilityTimeoutOpt = attributes.parseOptionalLong(VisibilityTimeoutParameter)
+          val secondsVisibilityTimeout = secondsVisibilityTimeoutOpt.getOrElse(DefaultVisibilityTimeout)
 
-          val secondsDelay = attributes.parseOptionalLong(DelaySecondsAttribute)
-            .getOrElse(DefaultDelay)
+          val secondsDelayOpt = attributes.parseOptionalLong(DelaySecondsAttribute)
+          val secondsDelay = secondsDelayOpt.getOrElse(DefaultDelay)
 
           val secondsReceiveMessageWaitTimeOpt = attributes.parseOptionalLong(ReceiveMessageWaitTimeSecondsAttribute)
           val secondsReceiveMessageWaitTime = secondsReceiveMessageWaitTimeOpt
@@ -44,9 +44,12 @@ trait CreateQueueDirectives { this: ElasticMQDirectives with QueueURLModule with
 
             val queueData = await(lookupOrCreateQueue(newQueueData))
 
-            if ((queueData.delay.getStandardSeconds != secondsDelay) ||
-              (queueData.receiveMessageWait.getStandardSeconds != secondsReceiveMessageWaitTime) ||
-              (queueData.defaultVisibilityTimeout.seconds != secondsVisibilityTimeout)) {
+            // if the request set the attributes compare them against the queue
+            if ((!secondsDelayOpt.isEmpty && queueData.delay.getStandardSeconds != secondsDelay) ||
+              (!secondsReceiveMessageWaitTimeOpt.isEmpty 
+                  && queueData.receiveMessageWait.getStandardSeconds != secondsReceiveMessageWaitTime) ||
+              (!secondsVisibilityTimeoutOpt.isEmpty 
+                  && queueData.defaultVisibilityTimeout.seconds != secondsVisibilityTimeout)) {
               // Special case: the queue existed, but has different attributes
               throw new SQSException("AWS.SimpleQueueService.QueueNameExists")
             }