Formatting

Author: acogoluegnes

src/main/java/com/rabbitmq/utility/BlockingCell.java

@@ -63,8 +63,9 @@ public synchronized T get() throws InterruptedException {
     public synchronized T get(long timeout) throws InterruptedException, TimeoutException {
         if (timeout == INFINITY) return get();
 
-        if (timeout < 0)
+        if (timeout < 0) {
             throw new AssertionError("Timeout cannot be less than zero");
+        }
 
         long now = System.nanoTime() / NANOS_IN_MILLI;
         long maxTime = now + timeout;
@@ -94,8 +95,9 @@ public synchronized T uninterruptibleGet() {
                 }
             }
         } finally {
-            if (wasInterrupted)
+            if (wasInterrupted) {
                 Thread.currentThread().interrupt();
+            }
         }
     }
 
@@ -122,8 +124,9 @@ public synchronized T uninterruptibleGet(int timeout) throws TimeoutException {
                 }
             } while ((timeout == INFINITY) || ((now = System.nanoTime() / NANOS_IN_MILLI) < runTime));
         } finally {
-            if (wasInterrupted)
+            if (wasInterrupted) {
                 Thread.currentThread().interrupt();
+            }
         }
 
         throw new TimeoutException();

src/main/java/com/rabbitmq/utility/SingleShotLinearTimer.java

@@ -31,7 +31,10 @@
  * package-private.
  * 
  * We currently just use this to time the quiescing RPC in AMQChannel.
- * 
+ *
+ * Will be removed in next major release.
+ *
+ * @deprecated
  * @see AMQChannel
  */