Change type of expires argument from (signed)long to signedint since that's the best we can do in 0-8.

Author: Simon MacMullen

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

@@ -46,7 +46,7 @@ public class QueueLease extends BrokerTestCase {
 
     // Currently the expiration timer is very responsive but this may
     // very well change in the future, so tweak accordingly.
-    private final static long QUEUE_EXPIRES = 1000L; // msecs
+    private final static int QUEUE_EXPIRES = 1000; // msecs
     private final static int SHOULD_EXPIRE_WITHIN = 2000;
 
     /**
@@ -67,25 +67,25 @@ public void testDoesNotExpireOthers() throws IOException,
 
     /**
      * Verify that the server throws an error if the type of x-expires is not
-     * long.
+     * int.
      */
-    public void testExpireMustBeLong() throws IOException {
+    public void testExpireMustBeInt() throws IOException {
         Map<String, Object> args = new HashMap<String, Object>();
-        args.put("x-expires", 100);
+        args.put("x-expires", 100L);
 
         try {
             channel
                     .queueDeclare("expiresMustBeLong", false, false, false,
                             args);
-            fail("server accepted x-expires not of type long");
+            fail("server accepted x-expires not of type int");
         } catch (IOException e) {
             checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
         }
     }
 
     public void testExpireMustBeGtZero() throws IOException {
         Map<String, Object> args = new HashMap<String, Object>();
-        args.put("x-expires", 0L);
+        args.put("x-expires", 0);
 
         try {
             channel.queueDeclare("expiresMustBeGtZero", false, false, false,
@@ -98,7 +98,7 @@ public void testExpireMustBeGtZero() throws IOException {
 
     public void testExpireMustBePositive() throws IOException {
         Map<String, Object> args = new HashMap<String, Object>();
-        args.put("x-expires", -10L);
+        args.put("x-expires", -10);
 
         try {
             channel.queueDeclare("expiresMustBePositive", false, false, false,
@@ -115,9 +115,9 @@ public void testExpireMustBePositive() throws IOException {
      */
     public void testQueueRedeclareEquivalence() throws IOException {
         Map<String, Object> args1 = new HashMap<String, Object>();
-        args1.put("x-expires", 10000L);
+        args1.put("x-expires", 10000);
         Map<String, Object> args2 = new HashMap<String, Object>();
-        args2.put("x-expires", 20000L);
+        args2.put("x-expires", 20000);
 
         channel.queueDeclare(TEST_EXPIRE_REDECLARE_QUEUE, false, false, false,
                 args1);
@@ -145,6 +145,7 @@ void verifyQueueExpires(String name, boolean expire) throws IOException,
         try {
             channel.queueDeclarePassive(name);
         } catch (IOException e) {
+            checkShutdownSignal(AMQP.NOT_FOUND, e);
             fail("Queue expired before deadline.");
         }