fleshed out functional tests for per queue ttl

Author: Rob Harrop

test/src/com/rabbitmq/client/test/functional/FunctionalTests.java

@@ -68,6 +68,7 @@ public static TestSuite suite() {
         suite.addTestSuite(RecoverAfterCancel.class);
         suite.addTestSuite(UnexpectedFrames.class);
         suite.addTestSuite(PerQueueTTL.class);
+        
         return suite;
     }
 }

test/src/com/rabbitmq/client/test/functional/PerQueueTTL.java

@@ -62,9 +62,34 @@ protected void releaseResources() throws IOException {
         this.channel.exchangeDelete(TTL_EXCHANGE);
     }
 
-    public void testCreateQueueWithTTL() throws IOException {
-        AMQP.Queue.DeclareOk declareOk = declareQueue(TTL_QUEUE_NAME, 2000L);
-        assertNotNull(declareOk);
+    public void testCreateQueueWithByteTTL() throws IOException {
+        try {
+            declareQueue(TTL_QUEUE_NAME, (byte)200);
+        }   catch(IOException ex) {
+            fail("Should be able to use long for queue TTL");
+        }
+    }
+    public void testCreateQueueWithShortTTL() throws IOException {
+        try {
+            declareQueue(TTL_QUEUE_NAME, (short)200);
+        }   catch(IOException ex) {
+            fail("Should be able to use long for queue TTL");
+        }
+    }
+    public void testCreateQueueWithIntTTL() throws IOException {
+        try {
+            declareQueue(TTL_QUEUE_NAME, 200);
+        }   catch(IOException ex) {
+            fail("Should be able to use long for queue TTL");
+        }
+    }
+
+    public void testCreateQueueWithLongTTL() throws IOException {
+        try {
+            declareQueue(TTL_QUEUE_NAME, 200L);
+        }   catch(IOException ex) {
+            fail("Should be able to use long for queue TTL");
+        }
     }
 
     public void testCreateQueueWithInvalidTTL() throws Exception {
@@ -76,7 +101,7 @@ public void testCreateQueueWithInvalidTTL() throws Exception {
         }
     }
 
-    public void testCreateQueueWithZeroTTL() throws Exception {
+    public void testTTLMustBeGtZero() throws Exception {
         try {
             declareQueue(TTL_INVALID_QUEUE_NAME, 0);
             fail("Should not be able to declare a queue with zero for x-message-ttl");
@@ -85,6 +110,24 @@ public void testCreateQueueWithZeroTTL() throws Exception {
         }
     }
 
+    public void testTTLMustBePositive() throws Exception {
+        try {
+            declareQueue(TTL_INVALID_QUEUE_NAME, -10);
+            fail("Should not be able to declare a queue with zero for x-message-ttl");
+        } catch (IOException e) {
+            assertNotNull(e);
+        }
+    }
+
+    public void testQueueRedeclareEquivalence() throws Exception {
+        declareQueue(TTL_QUEUE_NAME, 10);
+        try {
+             declareQueue(TTL_QUEUE_NAME, 20);
+        } catch(IOException ex) {
+            checkShutdownSignal(AMQP.NOT_ALLOWED, ex);
+        }
+    }
+
     /*
      * Test messages expire when using basic get.
      */