cosmetic

Author: Tim Watson

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

@@ -32,9 +32,9 @@
  */
 public class PerQueueTTL extends BrokerTestCase {
 
-    private static final String TTL_EXCHANGE           = "ttl.exchange";
-    private static final String TTL_ARG                = "x-message-ttl";
-    private static final String TTL_QUEUE_NAME         = "queue.ttl";
+    private static final String TTL_EXCHANGE = "ttl.exchange";
+    private static final String TTL_ARG = "x-message-ttl";
+    private static final String TTL_QUEUE_NAME = "queue.ttl";
     private static final String TTL_INVALID_QUEUE_NAME = "invalid.queue.ttl";
 
     private static final String[] MSG = {"one", "two", "three"};
@@ -50,13 +50,13 @@ protected void releaseResources() throws IOException {
     }
 
     public void testCreateQueueTTLTypes() throws IOException {
-        Object[] args = { (byte)200, (short)200, 200, 200L };
+        Object[] args = {(byte) 200, (short) 200, 200, 200L};
         for (Object ttl : args) {
             try {
                 declareQueue(ttl);
-            } catch(IOException ex) {
+            } catch (IOException ex) {
                 fail("Should be able to use " + ttl.getClass().getName() +
-                     " for x-message-ttl");
+                        " for x-message-ttl");
             }
         }
     }
@@ -92,15 +92,15 @@ public void testQueueRedeclareEquivalence() throws Exception {
         try {
             declareQueue(20);
             fail("Should not be able to redeclare with different x-message-ttl");
-        } catch(IOException ex) {
+        } catch (IOException ex) {
             checkShutdownSignal(AMQP.PRECONDITION_FAILED, ex);
         }
     }
 
     public void testQueueRedeclareSemanticEquivalence() throws Exception {
-        declareQueue((byte)10);
+        declareQueue((byte) 10);
         declareQueue(10);
-        declareQueue((short)10);
+        declareQueue((short) 10);
         declareQueue(10L);
     }
 
@@ -109,7 +109,7 @@ public void testQueueRedeclareSemanticNonEquivalence() throws Exception {
         try {
             declareQueue(10.0);
             fail("Should not be able to redeclare with x-message-ttl argument of different type");
-        } catch(IOException ex) {
+        } catch (IOException ex) {
             checkShutdownSignal(AMQP.PRECONDITION_FAILED, ex);
         }
     }
@@ -238,7 +238,7 @@ private AMQP.Queue.DeclareOk declareQueue(String name, Object ttlValue) throws I
     private void expectBodyAndRemainingMessages(String body, int messagesLeft) throws IOException {
         GetResponse response = channel.basicGet(TTL_QUEUE_NAME, false);
         assertEquals(body, new String(response.getBody()));
-        assertEquals(messagesLeft,  response.getMessageCount());
+        assertEquals(messagesLeft, response.getMessageCount());
     }
 
 }