space before {

Author: David R. MacIver

src/com/rabbitmq/client/Channel.java

@@ -61,7 +61,7 @@
  *
  */
 
-public interface Channel extends ShutdownNotifier{
+public interface Channel extends ShutdownNotifier {
     /**
      * Retrieve this channel's channel number.
      * @return the channel number

src/com/rabbitmq/client/ShutdownSignalException.java

@@ -40,7 +40,7 @@
  * this exception.
  */
 
-public class ShutdownSignalException extends RuntimeException implements SensibleClone<ShutdownSignalException>{
+public class ShutdownSignalException extends RuntimeException implements SensibleClone<ShutdownSignalException> {
     /** True if the connection is shut down, or false if this signal refers to a channel */
     private final boolean _hardError;
 
@@ -94,10 +94,10 @@ public ShutdownSignalException(boolean hardError,
     /** @return Reference to Connection or Channel object that fired the signal **/
     public Object getReference() { return _ref; }
 
-    public ShutdownSignalException sensibleClone(){
+    public ShutdownSignalException sensibleClone() {
         try {
             return (ShutdownSignalException)super.clone();
-        } catch (CloneNotSupportedException e){
+        } catch (CloneNotSupportedException e) {
             // You've got to be kidding me
             throw new Error(e);
         }

src/com/rabbitmq/utility/Utility.java

@@ -39,8 +39,8 @@
  */
 
 public class Utility {
-    static class ThrowableCreatedElsewhere extends Throwable{
-        public ThrowableCreatedElsewhere(Throwable throwable){
+    static class ThrowableCreatedElsewhere extends Throwable {
+        public ThrowableCreatedElsewhere(Throwable throwable) {
           super(throwable.getClass() + " created elsewhere");
           this.setStackTrace(throwable.getStackTrace());
         }
@@ -50,10 +50,10 @@ public ThrowableCreatedElsewhere(Throwable throwable){
         } 
     }
 
-    public static <T extends Throwable & SensibleClone<T>> T fixStackTrace(T throwable){
+    public static <T extends Throwable & SensibleClone<T>> T fixStackTrace(T throwable) {
       throwable = throwable.sensibleClone();
 
-      if(throwable.getCause() == null){
+      if(throwable.getCause() == null) {
         // We'd like to preserve the original stack trace in the cause.
         // Unfortunately Java doesn't let you set the cause once it's been
         // set once. This means we have to choose between either 
@@ -65,7 +65,7 @@ public static <T extends Throwable & SensibleClone<T>> T fixStackTrace(T throwab
         // doesn't matter too much. 
         try {
           throwable.initCause(new ThrowableCreatedElsewhere(throwable));
-        } catch(IllegalStateException e){
+        } catch(IllegalStateException e) {
           // This exception was explicitly initialised with a null cause. 
           // Alas this means we can't set the cause even though it has none. 
           // Thanks. 

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

@@ -38,12 +38,12 @@
 
 
 public class ValueOrExceptionTest extends TestCase {
-    public static class InsufficientMagicException extends Exception implements SensibleClone<InsufficientMagicException>{
-      public InsufficientMagicException(String message){
+    public static class InsufficientMagicException extends Exception implements SensibleClone<InsufficientMagicException> {
+      public InsufficientMagicException(String message) {
         super(message);
       }
 
-      public InsufficientMagicException sensibleClone(){
+      public InsufficientMagicException sensibleClone() {
         return new InsufficientMagicException(getMessage());
       }
     }

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

@@ -213,7 +213,7 @@ public static void main(String[] args) throws Exception {
     }
 
 
-    public Results run() throws Exception{
+    public Results run() throws Exception {
         Connection con = new ConnectionFactory().newConnection(params.host, params.port);
         Channel channel = con.createChannel();
 

test/src/com/rabbitmq/client/test/server/DurableBindingLifecycle.java

@@ -76,7 +76,7 @@ public void testDurableBindingRecovery() throws IOException {
 
         restart();
 
-        for (int i = 0; i < N; i++){
+        for (int i = 0; i < N; i++) {
             basicPublishVolatile(X, K);
         }
 
@@ -113,7 +113,7 @@ public void testDurableBindingsDeletion() throws IOException {
 
         declareDurableTopicExchange(X);
 
-        for (int i = 0; i < N; i++){
+        for (int i = 0; i < N; i++) {
             basicPublishVolatile(X, K);
         }
 

test/src/com/rabbitmq/examples/ManyConnections.java

@@ -90,7 +90,7 @@ public void run() {
 
     public static void runChannel(int threadNumber,
 				  Connection conn,
-				  Channel ch){
+				  Channel ch) {
 	try {
 	    int delayLen = (int) (1000 / rate);
 	    long startTime = System.currentTimeMillis();