cosmetic: tabs->spaces, removal of trailing spaces

Author: Matthias Radestock

src/com/rabbitmq/client/AlreadyClosedException.java

@@ -5,8 +5,8 @@
  * which was already closed
  */
 public class AlreadyClosedException extends ShutdownSignalException {
-	public AlreadyClosedException(String s, Object ref)
-	{
-		super(true, true, s, ref);
-	}
+    public AlreadyClosedException(String s, Object ref)
+    {
+        super(true, true, s, ref);
+    }
 }

src/com/rabbitmq/client/Channel.java

@@ -34,7 +34,7 @@
 
 /**
  * Public API: Interface to an AMQ channel. See the <a href="http://www.amqp.org/">spec</a> for details.
- *  
+ *
  * <p>
  * To open a channel,
  * <pre>
@@ -49,11 +49,11 @@
  *  <li> close
  * </ul>
  * <p>
- * 
- * While a Channel can be used by multiple threads, it's important to ensure 
+ *
+ * While a Channel can be used by multiple threads, it's important to ensure
  * that only one thread executes a command at once. Concurrent execution of
  * commands will likely cause an UnexpectedFrameError to be thrown.
- * 
+ *
  */
 
 public interface Channel extends ShutdownNotifier{
@@ -77,22 +77,22 @@ public interface Channel extends ShutdownNotifier{
      */
     void close(int closeCode, String closeMessage) throws IOException;
 
-    /** 
+    /**
      * Return the current {@link ReturnListener}.
-     * @return an interface to the current return listener 
+     * @return an interface to the current return listener
      */
     ReturnListener getReturnListener();
 
     /**
-     * Set the current {@link ReturnListener}. 
+     * Set the current {@link ReturnListener}.
      * @param listener the listener to use, or null indicating "don't use one".
      */
     void setReturnListener(ReturnListener listener);
 
     /**
      * Request a non-exclusive access ticket for the specified realm.
      * The access ticket is valid within the current channel and for the lifespan of the channel.
-     * 
+     *
      * @see com.rabbitmq.client.AMQP.Access.Request
      * @param realm the name of the realm
      * @return a valid access ticket
@@ -330,7 +330,7 @@ Queue.DeclareOk queueDeclare(int ticket, String queue, boolean passive, boolean
      * containing the received message being acknowledged.
      * @see com.rabbitmq.client.AMQP.Basic.Ack
      * @param deliveryTag the tag from the received {@link com.rabbitmq.client.AMQP.Basic.GetOk} or {@link com.rabbitmq.client.AMQP.Basic.Deliver}
-     * @param multiple true if we are acknowledging multiple messages with the same delivery tag 
+     * @param multiple true if we are acknowledging multiple messages with the same delivery tag
      * @throws java.io.IOException if an error is encountered
      */
     void basicAck(long deliveryTag, boolean multiple) throws IOException;

src/com/rabbitmq/client/Connection.java

@@ -30,7 +30,7 @@
  * Public API: Interface to an AMQ connection. See the see the <a href="http://www.amqp.org/">spec</a> for details.
  * <p>
  * To connect to a broker, fill in a {@link ConnectionParameters} and use a {@link ConnectionFactory} as follows:
- * 
+ *
  * <pre>
  * ConnectionParameters params = new ConnectionParameters();
  * params.setUsername(userName);
@@ -41,7 +41,7 @@
  * Connection conn = factory.newConnection(hostName, AMQP.PROTOCOL.PORT);
  *
  * // Then open a channel and retrieve an access ticket:
- * 
+ *
  * Channel channel = conn.createChannel();
  * int ticket = channel.accessRequest(realmName);
  * </pre>
@@ -104,7 +104,7 @@ public interface Connection extends ShutdownNotifier { // rename to AMQPConnecti
      * @return an array of addresses for all hosts that came back in the initial {@link com.rabbitmq.client.AMQP.Connection.OpenOk} open-ok method
      */
     Address[] getKnownHosts();
-    
+
     /**
      * Create a new channel, using an internally allocated channel number.
      * @return a new channel descriptor, or null if none is available
@@ -119,20 +119,20 @@ public interface Connection extends ShutdownNotifier { // rename to AMQPConnecti
      * @throws IOException if an I/O problem is encountered
      */
     Channel createChannel(int channelNumber) throws IOException;
-    
+
     /**
      * Close this connection and all its channels.
-     * 
+     *
      * This method will wait infinitely for all the close operations to
      * complete.
-     * 
+     *
      * @throws IOException if an I/O problem is encountered
      */
     void close() throws IOException;
-    
+
     /**
      * Close this connection and all its channels
-     * 
+     *
      * This method will wait with the given timeout for all the close
      * operations to complete. If timeout is reached then socket is forced
      * to close
@@ -141,22 +141,22 @@ public interface Connection extends ShutdownNotifier { // rename to AMQPConnecti
      * @throws IOException if an I/O problem is encountered
      */
     void close(int timeout) throws IOException;
-    
+
     /**
      * Abort this connection and all its channels.
-     * 
+     *
      * This method will force the connection to close. It will silently discard
      * any exceptions enountered in close operations
      */
     void abort();
-    
+
     /**
      * Abort this connection and all its channels.
-     * 
+     *
      * This method behaves in a similar way as abort(), with the only difference
      * that it will wait with a provided timeout for all the close operations to
      * complete. If timeout is reached socket is forced to close.
-     * 
+     *
      * @param timeout timeout (in miliseconds) for completing all the close-related
      * operations, use -1 for infinity
      */

src/com/rabbitmq/client/ConnectionParameters.java

@@ -59,7 +59,7 @@ private static String safeGetProperty(String key, String def) {
     /** Default value for desired heartbeat interval; zero for none */
     public static final int DEFAULT_HEARTBEAT = 3;
 
-    /** 
+    /**
      * Default value for suppressAccessRequest flag. Retrieved from
      * system property
      * "com.rabbitmq.client.ConnectionParameters.suppressAccessRequest"
@@ -112,7 +112,7 @@ public String getPassword() {
     public void setPassword(String password) {
         _password = password;
     }
-    
+
     /**
      * Retrieve the virtual host.
      * @return the virtual host to use when connecting to the broker
@@ -188,7 +188,7 @@ public boolean getSuppressAccessRequest() {
 
     /**
      * Enable or disable the suppression of sending "access.request"
-     * methods. 
+     * methods.
      * @param suppressAccessRequest true of "access.request" methods are suppressed, false otherwise.
      */
     public void setSuppressAccessRequest(boolean suppressAccessRequest) {

src/com/rabbitmq/client/ContentHeader.java

@@ -30,7 +30,7 @@
  */
 
 public interface ContentHeader {
-    /** 
+    /**
      * Retrieve the class ID (see the spec for a list of allowable IDs).
      * @return class ID of this ContentHeader. Properly an unsigned short, i.e. only the lowest 16 bits are significant
      */

src/com/rabbitmq/client/GetResponse.java

@@ -28,7 +28,7 @@
 
 /**
  * Encapsulates the response from a {@link Channel#basicGet} message-retrieval method call
- * - essentially a static bean "holder" with message response data. 
+ * - essentially a static bean "holder" with message response data.
  */
 public class GetResponse {
     private final Envelope envelope;
@@ -44,11 +44,11 @@ public class GetResponse {
      * @param messageCount the number of messages in the response
      */
     public GetResponse(Envelope envelope, BasicProperties props, byte[] body, int messageCount)
-    { 
-        this.envelope = envelope; 
-        this.props = props; 
-        this.body = body; 
-        this.messageCount = messageCount; 
+    {
+        this.envelope = envelope;
+        this.props = props;
+        this.body = body;
+        this.messageCount = messageCount;
     }
 
     /**

src/com/rabbitmq/client/Method.java

@@ -43,7 +43,7 @@ public interface Method {
     int protocolMethodId(); /* properly an unsigned short */
 
     /**
-     * Retrieve the method name  
+     * Retrieve the method name
      * @return the AMQP protocol method name of this Method
      */
     String protocolMethodName();

src/com/rabbitmq/client/ReturnListener.java

@@ -34,11 +34,11 @@
  * @see Channel#basicPublish
  */
 public interface ReturnListener {
-    void handleBasicReturn(int replyCode, 
-            String replyText, 
-            String exchange, 
-            String routingKey, 
-            AMQP.BasicProperties properties, 
-            byte[] body) 
-    throws IOException;
+    void handleBasicReturn(int replyCode,
+            String replyText,
+            String exchange,
+            String routingKey,
+            AMQP.BasicProperties properties,
+            byte[] body)
+        throws IOException;
 }

src/com/rabbitmq/client/ShutdownListener.java

@@ -3,7 +3,7 @@
 import java.util.EventListener;
 
 public interface ShutdownListener extends EventListener {
-	
-	public void shutdownCompleted(ShutdownSignalException cause);
+
+    public void shutdownCompleted(ShutdownSignalException cause);
 
 }

src/com/rabbitmq/client/ShutdownNotifier.java

@@ -3,46 +3,46 @@
 /**
  * Interface for components that are shutdown capable and
  * that allow listeners to be added for shutdown signals
- * 
+ *
  * @see ShutdownListener
  * @see ShutdownSignalException
  */
 public interface ShutdownNotifier {
     /**
      * Add shutdown listener.
      * If the component is already closed, handler is fired immediately
-     * 
+     *
      * @param listener {@link ShutdownListener} to the component
      */
     public void addShutdownListener(ShutdownListener listener);
-    
+
     /**
      * Remove shutdown listener for the component.
-     * 
+     *
      * @param listener {@link ShutdownListener} to be removed
      */
     public void removeShutdownListener(ShutdownListener listener);
-    
+
     /**
      * Get the shutdown reason object
      * @return ShutdownSignalException if component is closed, null otherwise
      */
     public ShutdownSignalException getCloseReason();
-    
+
     /**
      * Protected API - notify the listeners attached to the component
      * @see com.rabbitmq.client.ShutdownListener
      */
     public void notifyListeners();
-    
+
     /**
      * Determine whether the component is currently open.
      * Will return false if we are currently closing.
      * Checking this method should be only for information,
      * because of the race conditions - state can change after the call.
      * Instead just execute and try to catch ShutdownSignalException
      * and IOException
-     * 
+     *
      * @return true when component is open, false otherwise
      */
     boolean isOpen();

src/com/rabbitmq/client/ShutdownSignalException.java

@@ -56,7 +56,7 @@ public class ShutdownSignalException extends RuntimeException {
      * @param reason Object describing the origin of the exception
      * @param ref Reference to Connection or Channel that fired the signal
      */
-    public ShutdownSignalException(boolean hardError,   
+    public ShutdownSignalException(boolean hardError,
                                    boolean initiatedByApplication,
                                    Object reason, Object ref)
     {
@@ -69,16 +69,16 @@ public ShutdownSignalException(boolean hardError,
 
     /** @return true if this signals a connection error, or false if a channel error */
     public boolean isHardError() { return _hardError; }
-    
+
     /** @return true if this exception was caused by explicit application
      * action; false if it originated with the broker or as a result
      * of detectable non-deliberate application failure
      */
     public boolean isInitiatedByApplication() { return _initiatedByApplication; }
-    
+
     /** @return the reason object, if any */
     public Object getReason() { return _reason; }
-    
+
     /** @return Reference to Connection or Channel object that fired the signal **/
     public Object getReference() { return _ref; }
 

src/com/rabbitmq/client/UnexpectedFrameError.java

@@ -51,5 +51,5 @@ public Frame getReceivedFrame() {
 
     public int getExpectedFrameType() {
         return _expectedFrameType;
-    }   
+    }
 }

src/com/rabbitmq/client/impl/AMQChannel.java

@@ -38,7 +38,7 @@
  * Base class modelling an AMQ channel. Subclasses implement close()
  * and processAsync(), and may choose to override
  * processShutdownSignal().
- * 
+ *
  * @see ChannelN
  * @see Connection
  */
@@ -116,18 +116,18 @@ public AMQCommand exnWrappingRpc(Method m)
         try {
             return rpc(m);
         } catch (AlreadyClosedException ace) {
-        	// Do not wrap it since it means that connection/channel
-        	// was closed in some action in the past
-        	throw ace;
+            // Do not wrap it since it means that connection/channel
+            // was closed in some action in the past
+            throw ace;
         } catch (ShutdownSignalException ex) {
             throw wrap(ex);
         }
     }
-    
+
     /**
      * Private API - handle a command which has been assembled
      * @throws IOException if there's any problem
-     * 
+     *
      * @param command the incoming command
      * @throws IOException
      */
@@ -212,7 +212,7 @@ public AMQCommand quiescingRpc(Method m,
                                    final AMQCommand timeoutReply)
         throws IOException, ShutdownSignalException, TimeoutException
     {
-    	SimpleBlockingRpcContinuation k = new SimpleBlockingRpcContinuation();
+        SimpleBlockingRpcContinuation k = new SimpleBlockingRpcContinuation();
         transmitAndEnqueue(m, k);
         return k.getReply(timeoutMillisec);
     }
@@ -274,7 +274,7 @@ public T getReply() throws ShutdownSignalException
         {
             return _blocker.uninterruptibleGetValue();
         }
-        
+
         public T getReply(int timeout)
             throws ShutdownSignalException, TimeoutException
         {