fix trailing spaces

Author: David R. MacIver

src/com/rabbitmq/client/Channel.java

@@ -77,35 +77,35 @@ public interface Channel extends ShutdownNotifier{
     /**
      * Close this channel with the {@link com.rabbitmq.client.AMQP#REPLY_SUCCESS} close code
      * and message 'OK'.
-     * 
+     *
      * @throws java.io.IOException if an error is encountered
      */
     void close() throws IOException;
-    
+
     /**
      * Close this channel.
-     * 
+     *
      * @param closeCode the close code (See under "Reply Codes" in the AMQP specification)
      * @param closeMessage a message indicating the reason for closing the connection
      * @throws java.io.IOException if an error is encountered
      */
     void close(int closeCode, String closeMessage) throws IOException;
-    
+
     /**
      * Abort this channel with the {@link com.rabbitmq.client.AMQP#REPLY_SUCCESS} close code
      * and message 'OK'.
-     * 
+     *
      * Forces the channel to close and waits for the close operation to complete.
      * Any encountered exceptions in the close operation are silently discarded.
      */
     void abort() throws IOException;
-    
+
     /**
      * Abort this channel.
-     * 
+     *
      * Forces the channel to close and waits for the close operation to complete.
      * Any encountered exceptions in the close operation are silently discarded.
-     */    
+     */
     void abort(int closeCode, String closeMessage) throws IOException;
 
     /**
@@ -254,7 +254,7 @@ Exchange.DeclareOk exchangeDeclare(String exchange, String type, boolean passive
      * @throws java.io.IOException if an error is encountered
      */
     Queue.DeclareOk queueDeclare(String queue) throws IOException;
-    
+
     /**
      * Actively declare a non-exclusive, non-autodelete queue
      * The name of the new queue is held in the "queue" field of the {@link com.rabbitmq.client.AMQP.Queue.DeclareOk} result.
@@ -329,7 +329,7 @@ Queue.DeclareOk queueDeclare(String queue, boolean passive, boolean durable, boo
      * @throws java.io.IOException if an error is encountered
      */
     Queue.BindOk queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
-    
+
     /**
      * Unbinds a queue from an exchange, with no extra arguments.
      * @see com.rabbitmq.client.AMQP.Queue.Unbind
@@ -370,7 +370,7 @@ Queue.DeclareOk queueDeclare(String queue, boolean passive, boolean durable, boo
      * @see com.rabbitmq.client.AMQP.Queue.Purge
      * @see com.rabbitmq.client.AMQP.Queue.PurgeOk
      * @param queue the name of the queue
-     * @param nowait whether to await completion of the purge 
+     * @param nowait whether to await completion of the purge
      * @return a purge-confirm method if the purge was executed succesfully
      * @throws java.io.IOException if an error is encountered
      */

src/com/rabbitmq/tools/Tracer.java

@@ -79,26 +79,26 @@ private static class AsyncLogger extends Thread{
         final BlockingQueue<Object> queue = new ArrayBlockingQueue<Object>(LOG_QUEUE_SIZE, true);
         AsyncLogger(PrintStream ps){
             this.ps = new PrintStream(new BufferedOutputStream(ps, BUFFER_SIZE), false);
-            start(); 
+            start();
 
             new Thread(){
                 @Override public void run(){
                     while(true){
-                        try { 
-                            Thread.sleep(MAX_TIME_BETWEEN_FLUSHES); 
+                        try {
+                            Thread.sleep(MAX_TIME_BETWEEN_FLUSHES);
                             queue.add(FLUSH);
                         } catch(InterruptedException e) { }
                     }
-            
+
                 }
-            }.start();  
+            }.start();
         }
 
         void printMessage(Object message){
             if(message instanceof Throwable){
-                ((Throwable)message).printStackTrace(ps);    
+                ((Throwable)message).printStackTrace(ps);
             } else if (message instanceof String){
-                ps.println(message);          
+                ps.println(message);
             } else {
                 throw new RuntimeException("Unrecognised object " + message);
             }
@@ -116,13 +116,13 @@ void printMessage(Object message){
         }
 
         void log(Object message){
-            try {            
+            try {
               queue.put(message);
             } catch(InterruptedException ex){
               throw new RuntimeException(ex);
             }
         }
-    } 
+    }
 
     public static void main(String[] args) {
         int listenPort = args.length > 0 ? Integer.parseInt(args[0]) : 5673;
@@ -179,7 +179,7 @@ public Tracer(Socket sock, int id, String host, int port, AsyncLogger logger) th
         this.ios = new DataOutputStream(inSock.getOutputStream());
         this.ois = new DataInputStream(outSock.getInputStream());
         this.oos = new DataOutputStream(outSock.getOutputStream());
-        this.logger = logger; 
+        this.logger = logger;
 
         new Thread(this).start();
     }
@@ -297,7 +297,7 @@ public void doFrame() throws IOException {
                         AMQCommand cmd = c.handleFrame(f);
                         if (cmd != null) {
                             report(f.channel, cmd);
-                            assemblers.remove(f.channel); 
+                            assemblers.remove(f.channel);
                         }
                     }
                 }

src/com/rabbitmq/utility/BlockingValueOrException.java

@@ -46,7 +46,7 @@ public void setException(E e) {
     public V uninterruptibleGetValue() throws E {
         return uninterruptibleGet().getValue();
     }
-    
+
     public V uninterruptibleGetValue(int timeout) throws E, TimeoutException {
     	return uninterruptibleGet(timeout).getValue();
     }

src/com/rabbitmq/utility/Utility.java

@@ -39,7 +39,7 @@
  */
 
 public class Utility {
-  
+
     public static String makeStackTrace(Throwable throwable) {
         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
         PrintStream printStream = new PrintStream(outputStream);
@@ -49,7 +49,7 @@ public static String makeStackTrace(Throwable throwable) {
         try {
             outputStream.close();
         } catch (IOException ex) {
-            // Closing the output stream won't generate an error, and in 
+            // Closing the output stream won't generate an error, and in
             // fact does nothing - just being tidy
             ex.printStackTrace();
         }

src/com/rabbitmq/utility/ValueOrException.java

@@ -34,7 +34,7 @@ public class ValueOrException<V, E extends Throwable> {
     private final boolean _useValue;
     private final V _value;
     private final E _exception;
-    
+
     /**
      * dual-purpose private constructor: one will be null, and the flag tells which to use
      * @param value the value to wrap, if applicable
@@ -69,7 +69,7 @@ public static <V, E extends Throwable> ValueOrException<V, E> makeValue(V value)
     public static <V, E extends Throwable> ValueOrException<V, E> makeException(E exception) {
         return new ValueOrException<V, E>(null, exception, false);
     }
-    
+
     /** Retrieve value or throw exception
      * @return the wrapped value, if it's a value
      * @throws E the wrapped exception, if it's an exception

test/src/com/rabbitmq/client/test/ValueOrExceptionTest.java

@@ -49,7 +49,7 @@ public static TestSuite suite()
     public void testStoresValue() throws IOException {
         Integer value = new Integer(3);
         ValueOrException<Integer, IOException> valueOrEx = ValueOrException.<Integer, IOException>makeValue(value);
-        
+
         Integer returnedValue = valueOrEx.getValue();
         assertTrue(returnedValue == value);
     }

test/src/com/rabbitmq/client/test/performance/ScalabilityTest.java

@@ -144,7 +144,7 @@ public void print(final int base, final String prefix)
             s.close();
             s = open(prefix, "deletion");
             print(s, base, deletionTimes);
-            s.close(); 
+            s.close();
             s = open(prefix, "routing");
             print(s, base, transpose(routingTimes));
             s.close();