activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [46/53] [abbrv] [partial] activemq-artemis git commit: automatic checkstyle change
Date Mon, 10 Aug 2015 15:13:45 GMT
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQClusterSecurityException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQClusterSecurityException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQClusterSecurityException.java
index 8d53de7..6543e42 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQClusterSecurityException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQClusterSecurityException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * Security exception thrown when the cluster user fails authentication.
  */
-public final class ActiveMQClusterSecurityException extends ActiveMQException
-{
+public final class ActiveMQClusterSecurityException extends ActiveMQException {
+
    private static final long serialVersionUID = -5890578849781297933L;
 
-   public ActiveMQClusterSecurityException()
-   {
+   public ActiveMQClusterSecurityException() {
       super(ActiveMQExceptionType.CLUSTER_SECURITY_EXCEPTION);
    }
 
-   public ActiveMQClusterSecurityException(final String msg)
-   {
+   public ActiveMQClusterSecurityException(final String msg) {
       super(ActiveMQExceptionType.CLUSTER_SECURITY_EXCEPTION, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQConnectionTimedOutException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQConnectionTimedOutException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQConnectionTimedOutException.java
index 13c11dd..1b8a3c7 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQConnectionTimedOutException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQConnectionTimedOutException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A client timed out will connecting to ActiveMQ Artemis server.
  */
-public final class ActiveMQConnectionTimedOutException extends ActiveMQException
-{
+public final class ActiveMQConnectionTimedOutException extends ActiveMQException {
+
    private static final long serialVersionUID = 3244233758084830372L;
 
-   public ActiveMQConnectionTimedOutException()
-   {
+   public ActiveMQConnectionTimedOutException() {
       super(ActiveMQExceptionType.CONNECTION_TIMEDOUT);
    }
 
-   public ActiveMQConnectionTimedOutException(String msg)
-   {
+   public ActiveMQConnectionTimedOutException(String msg) {
       super(ActiveMQExceptionType.CONNECTION_TIMEDOUT, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDisconnectedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDisconnectedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDisconnectedException.java
index 2ce6882..45a0e7a 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDisconnectedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDisconnectedException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A client was disconnected from ActiveMQ Artemis server when the server has shut down.
  */
-public final class ActiveMQDisconnectedException extends ActiveMQException
-{
+public final class ActiveMQDisconnectedException extends ActiveMQException {
+
    private static final long serialVersionUID = 7414966383933311627L;
 
-   public ActiveMQDisconnectedException()
-   {
+   public ActiveMQDisconnectedException() {
       super(ActiveMQExceptionType.DISCONNECTED);
    }
 
-   public ActiveMQDisconnectedException(String message)
-   {
+   public ActiveMQDisconnectedException(String message) {
       super(ActiveMQExceptionType.DISCONNECTED, message);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateIdException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateIdException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateIdException.java
index 03260cd..c999aaf 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateIdException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateIdException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A DuplicateID was rejected.
  */
-public final class ActiveMQDuplicateIdException extends ActiveMQException
-{
+public final class ActiveMQDuplicateIdException extends ActiveMQException {
+
    private static final long serialVersionUID = -4302979339865777119L;
 
-   public ActiveMQDuplicateIdException()
-   {
+   public ActiveMQDuplicateIdException() {
       super(ActiveMQExceptionType.DUPLICATE_ID_REJECTED);
    }
 
-   public ActiveMQDuplicateIdException(String message)
-   {
+   public ActiveMQDuplicateIdException(String message) {
       super(ActiveMQExceptionType.DUPLICATE_ID_REJECTED, message);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateMetaDataException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateMetaDataException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateMetaDataException.java
index 40f2acb..a452011 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateMetaDataException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQDuplicateMetaDataException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A Session Metadata was set in duplication
  */
-public final class ActiveMQDuplicateMetaDataException extends ActiveMQException
-{
+public final class ActiveMQDuplicateMetaDataException extends ActiveMQException {
+
    private static final long serialVersionUID = 7877182872143004058L;
 
-   public ActiveMQDuplicateMetaDataException()
-   {
+   public ActiveMQDuplicateMetaDataException() {
       super(ActiveMQExceptionType.DUPLICATE_METADATA);
    }
 
-   public ActiveMQDuplicateMetaDataException(String msg)
-   {
+   public ActiveMQDuplicateMetaDataException(String msg) {
       super(ActiveMQExceptionType.DUPLICATE_METADATA, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQException.java
index 8fa3a18..13a35b1 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQException.java
@@ -19,19 +19,17 @@ package org.apache.activemq.artemis.api.core;
 /**
  * ActiveMQException is the root exception for the ActiveMQ Artemis API.
  */
-public class ActiveMQException extends Exception
-{
+public class ActiveMQException extends Exception {
+
    private static final long serialVersionUID = -4802014152804997417L;
 
    private final ActiveMQExceptionType type;
 
-   public ActiveMQException()
-   {
+   public ActiveMQException() {
       type = ActiveMQExceptionType.GENERIC_EXCEPTION;
    }
 
-   public ActiveMQException(final String msg)
-   {
+   public ActiveMQException(final String msg) {
       super(msg);
       type = ActiveMQExceptionType.GENERIC_EXCEPTION;
    }
@@ -39,39 +37,33 @@ public class ActiveMQException extends Exception
    /*
    * This constructor is needed only for the native layer
    */
-   public ActiveMQException(int code, String msg)
-   {
+   public ActiveMQException(int code, String msg) {
       super(msg);
 
       this.type = ActiveMQExceptionType.getType(code);
    }
 
-   public ActiveMQException(ActiveMQExceptionType type, String msg)
-   {
+   public ActiveMQException(ActiveMQExceptionType type, String msg) {
       super(msg);
 
       this.type = type;
    }
 
-   public ActiveMQException(ActiveMQExceptionType type)
-   {
+   public ActiveMQException(ActiveMQExceptionType type) {
       this.type = type;
    }
 
-   public ActiveMQException(ActiveMQExceptionType type, String message, Throwable t)
-   {
+   public ActiveMQException(ActiveMQExceptionType type, String message, Throwable t) {
       super(message, t);
       this.type = type;
    }
 
-   public ActiveMQExceptionType getType()
-   {
+   public ActiveMQExceptionType getType() {
       return type;
    }
 
    @Override
-   public String toString()
-   {
+   public String toString() {
       return this.getClass().getSimpleName() + "[errorType=" + type + " message=" + getMessage() + "]";
    }
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQExceptionType.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQExceptionType.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQExceptionType.java
index 700508e..6aca1d0 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQExceptionType.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQExceptionType.java
@@ -24,200 +24,151 @@ import java.util.Map;
 /**
  * Defines all {@link ActiveMQException} types and their codes.
  */
-public enum ActiveMQExceptionType
-{
+public enum ActiveMQExceptionType {
 
    // Error codes -------------------------------------------------
 
-   INTERNAL_ERROR(000)
-   {
+   INTERNAL_ERROR(000) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQInternalErrorException(msg);
       }
    },
-   UNSUPPORTED_PACKET(001)
-   {
+   UNSUPPORTED_PACKET(001) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQUnsupportedPacketException(msg);
       }
    },
-   NOT_CONNECTED(002)
-   {
+   NOT_CONNECTED(002) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQNotConnectedException(msg);
       }
    },
-   CONNECTION_TIMEDOUT(003)
-   {
+   CONNECTION_TIMEDOUT(003) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQConnectionTimedOutException(msg);
       }
    },
-   DISCONNECTED(004)
-   {
+   DISCONNECTED(004) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQDisconnectedException(msg);
       }
    },
-   UNBLOCKED(005)
-   {
+   UNBLOCKED(005) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQUnBlockedException(msg);
       }
    },
-   IO_ERROR(006)
-   {
+   IO_ERROR(006) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQIOErrorException(msg);
       }
    },
-   QUEUE_DOES_NOT_EXIST(100)
-   {
+   QUEUE_DOES_NOT_EXIST(100) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQNonExistentQueueException(msg);
       }
    },
-   QUEUE_EXISTS(101)
-   {
+   QUEUE_EXISTS(101) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQQueueExistsException(msg);
       }
    },
-   OBJECT_CLOSED(102)
-   {
+   OBJECT_CLOSED(102) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQObjectClosedException(msg);
       }
    },
-   INVALID_FILTER_EXPRESSION(103)
-   {
+   INVALID_FILTER_EXPRESSION(103) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQInvalidFilterExpressionException(msg);
       }
    },
-   ILLEGAL_STATE(104)
-   {
+   ILLEGAL_STATE(104) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQIllegalStateException(msg);
       }
    },
-   SECURITY_EXCEPTION(105)
-   {
+   SECURITY_EXCEPTION(105) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQSecurityException(msg);
       }
    },
-   ADDRESS_EXISTS(107)
-   {
+   ADDRESS_EXISTS(107) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQAddressExistsException(msg);
       }
    },
-   INCOMPATIBLE_CLIENT_SERVER_VERSIONS(108)
-   {
+   INCOMPATIBLE_CLIENT_SERVER_VERSIONS(108) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQIncompatibleClientServerException(msg);
       }
    },
-   LARGE_MESSAGE_ERROR_BODY(110)
-   {
+   LARGE_MESSAGE_ERROR_BODY(110) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQLargeMessageException(msg);
       }
    },
-   TRANSACTION_ROLLED_BACK(111)
-   {
+   TRANSACTION_ROLLED_BACK(111) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQTransactionRolledBackException(msg);
       }
    },
-   SESSION_CREATION_REJECTED(112)
-   {
+   SESSION_CREATION_REJECTED(112) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQSessionCreationException(msg);
       }
    },
-   DUPLICATE_ID_REJECTED(113)
-   {
+   DUPLICATE_ID_REJECTED(113) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQDuplicateIdException(msg);
       }
    },
-   DUPLICATE_METADATA(114)
-   {
+   DUPLICATE_METADATA(114) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQDuplicateMetaDataException(msg);
       }
    },
-   TRANSACTION_OUTCOME_UNKNOWN(115)
-   {
+   TRANSACTION_OUTCOME_UNKNOWN(115) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQTransactionOutcomeUnknownException(msg);
       }
    },
-   ALREADY_REPLICATING(116)
-   {
+   ALREADY_REPLICATING(116) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQAlreadyReplicatingException(msg);
       }
    },
-   INTERCEPTOR_REJECTED_PACKET(117)
-   {
+   INTERCEPTOR_REJECTED_PACKET(117) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQInterceptorRejectedPacketException(msg);
       }
    },
-   INVALID_TRANSIENT_QUEUE_USE(118)
-   {
+   INVALID_TRANSIENT_QUEUE_USE(118) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQInvalidTransientQueueUseException(msg);
       }
    },
@@ -232,27 +183,21 @@ public enum ActiveMQExceptionType
    NATIVE_ERROR_CANT_ALLOCATE_QUEUE(206),
    NATIVE_ERROR_PREALLOCATE_FILE(208),
    NATIVE_ERROR_ALLOCATE_MEMORY(209),
-   ADDRESS_FULL(210)
-   {
+   ADDRESS_FULL(210) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQAddressFullException(msg);
       }
    },
-   LARGE_MESSAGE_INTERRUPTED(211)
-   {
+   LARGE_MESSAGE_INTERRUPTED(211) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQLargeMessageInterruptedException(msg);
       }
    },
-   CLUSTER_SECURITY_EXCEPTION(212)
-   {
+   CLUSTER_SECURITY_EXCEPTION(212) {
       @Override
-      public ActiveMQException createException(String msg)
-      {
+      public ActiveMQException createException(String msg) {
          return new ActiveMQClusterSecurityException(msg);
       }
 
@@ -260,11 +205,9 @@ public enum ActiveMQExceptionType
 
    private static final Map<Integer, ActiveMQExceptionType> TYPE_MAP;
 
-   static
-   {
+   static {
       HashMap<Integer, ActiveMQExceptionType> map = new HashMap<Integer, ActiveMQExceptionType>();
-      for (ActiveMQExceptionType type : EnumSet.allOf(ActiveMQExceptionType.class))
-      {
+      for (ActiveMQExceptionType type : EnumSet.allOf(ActiveMQExceptionType.class)) {
          map.put(type.getCode(), type);
       }
       TYPE_MAP = Collections.unmodifiableMap(map);
@@ -272,28 +215,23 @@ public enum ActiveMQExceptionType
 
    private final int code;
 
-   ActiveMQExceptionType(int code)
-   {
+   ActiveMQExceptionType(int code) {
       this.code = code;
    }
 
-   public int getCode()
-   {
+   public int getCode() {
       return code;
    }
 
-   public ActiveMQException createException(String msg)
-   {
+   public ActiveMQException createException(String msg) {
       return new ActiveMQException(msg + ", code:" + this);
    }
 
-   public static ActiveMQException createException(int code, String msg)
-   {
+   public static ActiveMQException createException(int code, String msg) {
       return getType(code).createException(msg);
    }
 
-   public static ActiveMQExceptionType getType(int code)
-   {
+   public static ActiveMQExceptionType getType(int code) {
       ActiveMQExceptionType type = TYPE_MAP.get(code);
       if (type != null)
          return type;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIOErrorException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIOErrorException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIOErrorException.java
index f89ddbd..56973d4 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIOErrorException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIOErrorException.java
@@ -19,22 +19,19 @@ package org.apache.activemq.artemis.api.core;
 /**
  * Unexpected I/O error occurred on the server.
  */
-public final class ActiveMQIOErrorException extends ActiveMQException
-{
+public final class ActiveMQIOErrorException extends ActiveMQException {
+
    private static final long serialVersionUID = 797277117077787396L;
 
-   public ActiveMQIOErrorException()
-   {
+   public ActiveMQIOErrorException() {
       super(ActiveMQExceptionType.IO_ERROR);
    }
 
-   public ActiveMQIOErrorException(String msg)
-   {
+   public ActiveMQIOErrorException(String msg) {
       super(ActiveMQExceptionType.IO_ERROR, msg);
    }
 
-   public ActiveMQIOErrorException(String msg, Throwable cause)
-   {
+   public ActiveMQIOErrorException(String msg, Throwable cause) {
       super(ActiveMQExceptionType.IO_ERROR, msg, cause);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
index 8ad6b21..3ee855b 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIllegalStateException.java
@@ -20,17 +20,15 @@ package org.apache.activemq.artemis.api.core;
  * An ActiveMQ Artemis resource is not in a legal state (e.g. calling ClientConsumer.receive() if a
  * MessageHandler is set).
  */
-public final class ActiveMQIllegalStateException extends ActiveMQException
-{
+public final class ActiveMQIllegalStateException extends ActiveMQException {
+
    private static final long serialVersionUID = -4480125401057788511L;
 
-   public ActiveMQIllegalStateException()
-   {
+   public ActiveMQIllegalStateException() {
       super(ActiveMQExceptionType.ILLEGAL_STATE);
    }
 
-   public ActiveMQIllegalStateException(String message)
-   {
+   public ActiveMQIllegalStateException(String message) {
       super(ActiveMQExceptionType.ILLEGAL_STATE, message);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIncompatibleClientServerException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIncompatibleClientServerException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIncompatibleClientServerException.java
index 7522d10..0be739d 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIncompatibleClientServerException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQIncompatibleClientServerException.java
@@ -21,17 +21,15 @@ package org.apache.activemq.artemis.api.core;
  * <p>
  * Normally this means you are trying to use a newer client on an older server.
  */
-public final class ActiveMQIncompatibleClientServerException extends ActiveMQException
-{
+public final class ActiveMQIncompatibleClientServerException extends ActiveMQException {
+
    private static final long serialVersionUID = -1662999230291452298L;
 
-   public ActiveMQIncompatibleClientServerException()
-   {
+   public ActiveMQIncompatibleClientServerException() {
       super(ActiveMQExceptionType.INCOMPATIBLE_CLIENT_SERVER_VERSIONS);
    }
 
-   public ActiveMQIncompatibleClientServerException(String msg)
-   {
+   public ActiveMQIncompatibleClientServerException(String msg) {
       super(ActiveMQExceptionType.INCOMPATIBLE_CLIENT_SERVER_VERSIONS, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterceptorRejectedPacketException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterceptorRejectedPacketException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterceptorRejectedPacketException.java
index 57d60d4..e52c113 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterceptorRejectedPacketException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterceptorRejectedPacketException.java
@@ -21,17 +21,15 @@ package org.apache.activemq.artemis.api.core;
  * See org.apache.activemq.artemis.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq.artemis.api.core.Interceptor)
  */
 // XXX I doubt any reader will make much sense of this Javadoc's text.
-public final class ActiveMQInterceptorRejectedPacketException extends ActiveMQException
-{
+public final class ActiveMQInterceptorRejectedPacketException extends ActiveMQException {
+
    private static final long serialVersionUID = -5798841227645281815L;
 
-   public ActiveMQInterceptorRejectedPacketException()
-   {
+   public ActiveMQInterceptorRejectedPacketException() {
       super(ActiveMQExceptionType.INTERCEPTOR_REJECTED_PACKET);
    }
 
-   public ActiveMQInterceptorRejectedPacketException(String msg)
-   {
+   public ActiveMQInterceptorRejectedPacketException(String msg) {
       super(ActiveMQExceptionType.INTERCEPTOR_REJECTED_PACKET, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInternalErrorException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInternalErrorException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInternalErrorException.java
index 18a5b16..9da7d80 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInternalErrorException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInternalErrorException.java
@@ -19,27 +19,23 @@ package org.apache.activemq.artemis.api.core;
 /**
  * Internal error which prevented ActiveMQ Artemis from performing an important operation.
  */
-public final class ActiveMQInternalErrorException extends ActiveMQException
-{
+public final class ActiveMQInternalErrorException extends ActiveMQException {
+
    private static final long serialVersionUID = -5987814047521530695L;
 
-   public ActiveMQInternalErrorException()
-   {
+   public ActiveMQInternalErrorException() {
       super(ActiveMQExceptionType.INTERNAL_ERROR);
    }
 
-   public ActiveMQInternalErrorException(String msg)
-   {
+   public ActiveMQInternalErrorException(String msg) {
       super(ActiveMQExceptionType.INTERNAL_ERROR, msg);
    }
 
-   public ActiveMQInternalErrorException(String message, Exception e)
-   {
+   public ActiveMQInternalErrorException(String message, Exception e) {
       super(ActiveMQExceptionType.INTERNAL_ERROR, message, e);
    }
 
-   public ActiveMQInternalErrorException(String message, Throwable t)
-   {
+   public ActiveMQInternalErrorException(String message, Throwable t) {
       super(ActiveMQExceptionType.INTERNAL_ERROR, message, t);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterruptedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterruptedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterruptedException.java
index eee402b..9a3ff7f 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterruptedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInterruptedException.java
@@ -19,12 +19,11 @@ package org.apache.activemq.artemis.api.core;
 /**
  * When an interruption happens, we will just throw a non-checked exception.
  */
-public final class ActiveMQInterruptedException extends RuntimeException
-{
+public final class ActiveMQInterruptedException extends RuntimeException {
+
    private static final long serialVersionUID = -5744690023549671221L;
 
-   public ActiveMQInterruptedException(Throwable cause)
-   {
+   public ActiveMQInterruptedException(Throwable cause) {
       super(cause);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidFilterExpressionException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidFilterExpressionException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidFilterExpressionException.java
index 60397a2..f3b0950 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidFilterExpressionException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidFilterExpressionException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A filter expression was found to be invalid.
  */
-public final class ActiveMQInvalidFilterExpressionException extends ActiveMQException
-{
+public final class ActiveMQInvalidFilterExpressionException extends ActiveMQException {
+
    private static final long serialVersionUID = 7188625553939665128L;
 
-   public ActiveMQInvalidFilterExpressionException()
-   {
+   public ActiveMQInvalidFilterExpressionException() {
       super(ActiveMQExceptionType.INVALID_FILTER_EXPRESSION);
    }
 
-   public ActiveMQInvalidFilterExpressionException(String msg)
-   {
+   public ActiveMQInvalidFilterExpressionException(String msg) {
       super(ActiveMQExceptionType.INVALID_FILTER_EXPRESSION, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidTransientQueueUseException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidTransientQueueUseException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidTransientQueueUseException.java
index 8951004..13416d4 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidTransientQueueUseException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQInvalidTransientQueueUseException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * An operation failed because a queue exists on the server.
  */
-public final class ActiveMQInvalidTransientQueueUseException extends ActiveMQException
-{
+public final class ActiveMQInvalidTransientQueueUseException extends ActiveMQException {
+
    private static final long serialVersionUID = -405552292451883063L;
 
-   public ActiveMQInvalidTransientQueueUseException()
-   {
+   public ActiveMQInvalidTransientQueueUseException() {
       super(ActiveMQExceptionType.INVALID_TRANSIENT_QUEUE_USE);
    }
 
-   public ActiveMQInvalidTransientQueueUseException(String msg)
-   {
+   public ActiveMQInvalidTransientQueueUseException(String msg) {
       super(ActiveMQExceptionType.INVALID_TRANSIENT_QUEUE_USE, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageException.java
index c3f6636..9c68cc7 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A problem occurred while manipulating the body of a large message.
  */
-public final class ActiveMQLargeMessageException extends ActiveMQException
-{
+public final class ActiveMQLargeMessageException extends ActiveMQException {
+
    private static final long serialVersionUID = 1087867463974768491L;
 
-   public ActiveMQLargeMessageException()
-   {
+   public ActiveMQLargeMessageException() {
       super(ActiveMQExceptionType.LARGE_MESSAGE_ERROR_BODY);
    }
 
-   public ActiveMQLargeMessageException(String msg)
-   {
+   public ActiveMQLargeMessageException(String msg) {
       super(ActiveMQExceptionType.LARGE_MESSAGE_ERROR_BODY, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageInterruptedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageInterruptedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageInterruptedException.java
index 786bf7d..77c45b9 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageInterruptedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQLargeMessageInterruptedException.java
@@ -16,21 +16,18 @@
  */
 package org.apache.activemq.artemis.api.core;
 
-
 /**
  */
 // XXX
-public class ActiveMQLargeMessageInterruptedException extends ActiveMQException
-{
+public class ActiveMQLargeMessageInterruptedException extends ActiveMQException {
+
    private static final long serialVersionUID = 0;
 
-   public ActiveMQLargeMessageInterruptedException(String message)
-   {
+   public ActiveMQLargeMessageInterruptedException(String message) {
       super(ActiveMQExceptionType.LARGE_MESSAGE_INTERRUPTED, message);
    }
 
-   public ActiveMQLargeMessageInterruptedException()
-   {
+   public ActiveMQLargeMessageInterruptedException() {
       super(ActiveMQExceptionType.LARGE_MESSAGE_INTERRUPTED);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNativeIOError.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNativeIOError.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNativeIOError.java
index e69a7fd..1ed755d 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNativeIOError.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNativeIOError.java
@@ -16,27 +16,23 @@
  */
 package org.apache.activemq.artemis.api.core;
 
-
 /**
  * An error has happened at ActiveMQ's native (non-Java) code used in reading and writing data.
  */
 // XXX
-public final class ActiveMQNativeIOError extends ActiveMQException
-{
+public final class ActiveMQNativeIOError extends ActiveMQException {
+
    private static final long serialVersionUID = 2355120980683293085L;
 
-   public ActiveMQNativeIOError()
-   {
+   public ActiveMQNativeIOError() {
       super(ActiveMQExceptionType.NATIVE_ERROR_CANT_INITIALIZE_AIO);
    }
 
-   public ActiveMQNativeIOError(String msg)
-   {
+   public ActiveMQNativeIOError(String msg) {
       super(ActiveMQExceptionType.NATIVE_ERROR_CANT_INITIALIZE_AIO, msg);
    }
 
-   public ActiveMQNativeIOError(String msg, Throwable e)
-   {
+   public ActiveMQNativeIOError(String msg, Throwable e) {
       super(ActiveMQExceptionType.NATIVE_ERROR_CANT_INITIALIZE_AIO, msg, e);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNonExistentQueueException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNonExistentQueueException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNonExistentQueueException.java
index 7b6eb6a..79659bb 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNonExistentQueueException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNonExistentQueueException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * An operation failed because a queue does not exist on the server.
  */
-public final class ActiveMQNonExistentQueueException extends ActiveMQException
-{
+public final class ActiveMQNonExistentQueueException extends ActiveMQException {
+
    private static final long serialVersionUID = -8199298881947523607L;
 
-   public ActiveMQNonExistentQueueException()
-   {
+   public ActiveMQNonExistentQueueException() {
       super(ActiveMQExceptionType.QUEUE_DOES_NOT_EXIST);
    }
 
-   public ActiveMQNonExistentQueueException(String msg)
-   {
+   public ActiveMQNonExistentQueueException(String msg) {
       super(ActiveMQExceptionType.QUEUE_DOES_NOT_EXIST, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNotConnectedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNotConnectedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNotConnectedException.java
index 3a95fcd..19375a7 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNotConnectedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQNotConnectedException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A client is not able to connect to ActiveMQ Artemis server.
  */
-public final class ActiveMQNotConnectedException extends ActiveMQException
-{
+public final class ActiveMQNotConnectedException extends ActiveMQException {
+
    private static final long serialVersionUID = -3489189971813613325L;
 
-   public ActiveMQNotConnectedException(String message)
-   {
+   public ActiveMQNotConnectedException(String message) {
       super(ActiveMQExceptionType.NOT_CONNECTED, message);
    }
 
-   public ActiveMQNotConnectedException()
-   {
+   public ActiveMQNotConnectedException() {
       super(ActiveMQExceptionType.NOT_CONNECTED);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQObjectClosedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQObjectClosedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQObjectClosedException.java
index 7ad745f..06dad54 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQObjectClosedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQObjectClosedException.java
@@ -20,17 +20,15 @@ package org.apache.activemq.artemis.api.core;
  * A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is
  * closed.
  */
-public final class ActiveMQObjectClosedException extends ActiveMQException
-{
+public final class ActiveMQObjectClosedException extends ActiveMQException {
+
    private static final long serialVersionUID = 809024052184914812L;
 
-   public ActiveMQObjectClosedException()
-   {
+   public ActiveMQObjectClosedException() {
       super(ActiveMQExceptionType.OBJECT_CLOSED);
    }
 
-   public ActiveMQObjectClosedException(String msg)
-   {
+   public ActiveMQObjectClosedException(String msg) {
       super(ActiveMQExceptionType.OBJECT_CLOSED, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQPropertyConversionException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQPropertyConversionException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQPropertyConversionException.java
index 842a0fe..910f74f 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQPropertyConversionException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQPropertyConversionException.java
@@ -20,13 +20,11 @@ package org.apache.activemq.artemis.api.core;
  * A PropertyConversionException is thrown by {@code org.apache.activemq.artemis.api.core.Message} methods when a
  * property can not be converted to the expected type.
  */
-public final class ActiveMQPropertyConversionException extends RuntimeException
-{
+public final class ActiveMQPropertyConversionException extends RuntimeException {
 
    private static final long serialVersionUID = -3010008708334904332L;
 
-   public ActiveMQPropertyConversionException(final String message)
-   {
+   public ActiveMQPropertyConversionException(final String message) {
       super(message);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQQueueExistsException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQQueueExistsException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQQueueExistsException.java
index e88dc17..426deb8 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQQueueExistsException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQQueueExistsException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * An operation failed because a queue exists on the server.
  */
-public final class ActiveMQQueueExistsException extends ActiveMQException
-{
+public final class ActiveMQQueueExistsException extends ActiveMQException {
+
    private static final long serialVersionUID = -405552292451883063L;
 
-   public ActiveMQQueueExistsException()
-   {
+   public ActiveMQQueueExistsException() {
       super(ActiveMQExceptionType.QUEUE_EXISTS);
    }
 
-   public ActiveMQQueueExistsException(String msg)
-   {
+   public ActiveMQQueueExistsException(String msg) {
       super(ActiveMQExceptionType.QUEUE_EXISTS, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSecurityException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSecurityException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSecurityException.java
index b3ce7d2..da51b38 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSecurityException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSecurityException.java
@@ -21,17 +21,15 @@ import static org.apache.activemq.artemis.api.core.ActiveMQExceptionType.SECURIT
 /**
  * A security problem occurred (authentication issues, permission issues,...)
  */
-public final class ActiveMQSecurityException extends ActiveMQException
-{
+public final class ActiveMQSecurityException extends ActiveMQException {
+
    private static final long serialVersionUID = 3291210307590756881L;
 
-   public ActiveMQSecurityException()
-   {
+   public ActiveMQSecurityException() {
       super(SECURITY_EXCEPTION);
    }
 
-   public ActiveMQSecurityException(String msg)
-   {
+   public ActiveMQSecurityException(String msg) {
       super(SECURITY_EXCEPTION, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSessionCreationException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSessionCreationException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSessionCreationException.java
index c3af3f0..a2c973a 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSessionCreationException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQSessionCreationException.java
@@ -20,17 +20,15 @@ package org.apache.activemq.artemis.api.core;
  * The creation of a session was rejected by the server (e.g. if the server is starting and has not
  * finish to be initialized.
  */
-public final class ActiveMQSessionCreationException extends ActiveMQException
-{
+public final class ActiveMQSessionCreationException extends ActiveMQException {
+
    private static final long serialVersionUID = -4486139158452585895L;
 
-   public ActiveMQSessionCreationException()
-   {
+   public ActiveMQSessionCreationException() {
       super(ActiveMQExceptionType.SESSION_CREATION_REJECTED);
    }
 
-   public ActiveMQSessionCreationException(String msg)
-   {
+   public ActiveMQSessionCreationException(String msg) {
       super(ActiveMQExceptionType.SESSION_CREATION_REJECTED, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionOutcomeUnknownException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionOutcomeUnknownException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionOutcomeUnknownException.java
index 447cdca..d0e56a1 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionOutcomeUnknownException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionOutcomeUnknownException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * The outcome of a transaction is unknown.
  */
-public final class ActiveMQTransactionOutcomeUnknownException extends ActiveMQException
-{
+public final class ActiveMQTransactionOutcomeUnknownException extends ActiveMQException {
+
    private static final long serialVersionUID = 7940794286427650558L;
 
-   public ActiveMQTransactionOutcomeUnknownException()
-   {
+   public ActiveMQTransactionOutcomeUnknownException() {
       super(ActiveMQExceptionType.TRANSACTION_OUTCOME_UNKNOWN);
    }
 
-   public ActiveMQTransactionOutcomeUnknownException(String msg)
-   {
+   public ActiveMQTransactionOutcomeUnknownException(String msg) {
       super(ActiveMQExceptionType.TRANSACTION_OUTCOME_UNKNOWN, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionRolledBackException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionRolledBackException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionRolledBackException.java
index e6e4443..03e4c58 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionRolledBackException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQTransactionRolledBackException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A transaction was rolled back.
  */
-public final class ActiveMQTransactionRolledBackException extends ActiveMQException
-{
+public final class ActiveMQTransactionRolledBackException extends ActiveMQException {
+
    private static final long serialVersionUID = 5823412198677126300L;
 
-   public ActiveMQTransactionRolledBackException()
-   {
+   public ActiveMQTransactionRolledBackException() {
       super(ActiveMQExceptionType.TRANSACTION_ROLLED_BACK);
    }
 
-   public ActiveMQTransactionRolledBackException(String msg)
-   {
+   public ActiveMQTransactionRolledBackException(String msg) {
       super(ActiveMQExceptionType.TRANSACTION_ROLLED_BACK, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnBlockedException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnBlockedException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnBlockedException.java
index 19eb18c..5b2a421 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnBlockedException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnBlockedException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A blocking call from a client was unblocked during failover.
  */
-public final class ActiveMQUnBlockedException extends ActiveMQException
-{
+public final class ActiveMQUnBlockedException extends ActiveMQException {
+
    private static final long serialVersionUID = -4507889261891160608L;
 
-   public ActiveMQUnBlockedException()
-   {
+   public ActiveMQUnBlockedException() {
       super(ActiveMQExceptionType.UNBLOCKED);
    }
 
-   public ActiveMQUnBlockedException(String msg)
-   {
+   public ActiveMQUnBlockedException(String msg) {
       super(ActiveMQExceptionType.UNBLOCKED, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnsupportedPacketException.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnsupportedPacketException.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnsupportedPacketException.java
index c6cb764..377d2c5 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnsupportedPacketException.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/ActiveMQUnsupportedPacketException.java
@@ -19,17 +19,15 @@ package org.apache.activemq.artemis.api.core;
 /**
  * A packet of unsupported type was received by ActiveMQ Artemis PacketHandler.
  */
-public final class ActiveMQUnsupportedPacketException extends ActiveMQException
-{
+public final class ActiveMQUnsupportedPacketException extends ActiveMQException {
+
    private static final long serialVersionUID = -7074681529482463675L;
 
-   public ActiveMQUnsupportedPacketException()
-   {
+   public ActiveMQUnsupportedPacketException() {
       super(ActiveMQExceptionType.UNSUPPORTED_PACKET);
    }
 
-   public ActiveMQUnsupportedPacketException(String msg)
-   {
+   public ActiveMQUnsupportedPacketException(String msg) {
       super(ActiveMQExceptionType.UNSUPPORTED_PACKET, msg);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/Pair.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/Pair.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/Pair.java
index 4497c6f..b3e130f 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/Pair.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/Pair.java
@@ -23,12 +23,11 @@ import java.io.Serializable;
  * <p>
  * This is a utility class.
  */
-public final class Pair<A, B> implements Serializable
-{
+public final class Pair<A, B> implements Serializable {
+
    private static final long serialVersionUID = -2496357457812368127L;
 
-   public Pair(final A a, final B b)
-   {
+   public Pair(final A a, final B b) {
       this.a = a;
 
       this.b = b;
@@ -41,16 +40,12 @@ public final class Pair<A, B> implements Serializable
    private int hash = -1;
 
    @Override
-   public int hashCode()
-   {
-      if (hash == -1)
-      {
-         if (a == null && b == null)
-         {
+   public int hashCode() {
+      if (hash == -1) {
+         if (a == null && b == null) {
             return super.hashCode();
          }
-         else
-         {
+         else {
             hash = (a == null ? 0 : a.hashCode()) + 37 * (b == null ? 0 : b.hashCode());
          }
       }
@@ -59,49 +54,41 @@ public final class Pair<A, B> implements Serializable
    }
 
    @Override
-   public boolean equals(final Object other)
-   {
-      if (other == this)
-      {
+   public boolean equals(final Object other) {
+      if (other == this) {
          return true;
       }
 
-      if (other instanceof Pair == false)
-      {
+      if (other instanceof Pair == false) {
          return false;
       }
 
-      Pair<A, B> pother = (Pair<A, B>)other;
+      Pair<A, B> pother = (Pair<A, B>) other;
 
       return (pother.a == null ? a == null : pother.a.equals(a)) && (pother.b == null ? b == null : pother.b.equals(b));
 
    }
 
    @Override
-   public String toString()
-   {
+   public String toString() {
       return "Pair[a=" + a + ", b=" + b + "]";
    }
 
-   public void setA(A a)
-   {
+   public void setA(A a) {
       hash = -1;
       this.a = a;
    }
 
-   public A getA()
-   {
+   public A getA() {
       return a;
    }
 
-   public void setB(B b)
-   {
+   public void setB(B b) {
       hash = -1;
       this.b = b;
    }
 
-   public B getB()
-   {
+   public B getB() {
       return b;
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/SimpleString.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/SimpleString.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/SimpleString.java
index 3c8a35c..d50e46d 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/SimpleString.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/api/core/SimpleString.java
@@ -27,10 +27,9 @@ import org.apache.activemq.artemis.utils.DataConstants;
  * minimises expensive copying between String objects.
  * <p>
  * This object is used heavily throughout ActiveMQ Artemis for performance reasons.
- *
  */
-public final class SimpleString implements CharSequence, Serializable, Comparable<SimpleString>
-{
+public final class SimpleString implements CharSequence, Serializable, Comparable<SimpleString> {
+
    private static final long serialVersionUID = 4204223851422244307L;
 
    // Attributes
@@ -53,10 +52,8 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param string String used to instantiate a SimpleString.
     * @return A new SimpleString
     */
-   public static SimpleString toSimpleString(final String string)
-   {
-      if (string == null)
-      {
+   public static SimpleString toSimpleString(final String string) {
+      if (string == null) {
          return null;
       }
       return new SimpleString(string);
@@ -70,16 +67,14 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     *
     * @param string the string to transform
     */
-   public SimpleString(final String string)
-   {
+   public SimpleString(final String string) {
       int len = string.length();
 
       data = new byte[len << 1];
 
       int j = 0;
 
-      for (int i = 0; i < len; i++)
-      {
+      for (int i = 0; i < len; i++) {
          char c = string.charAt(i);
 
          byte low = (byte) (c & 0xFF); // low byte
@@ -99,23 +94,19 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     *
     * @param data the byte array to use
     */
-   public SimpleString(final byte[] data)
-   {
+   public SimpleString(final byte[] data) {
       this.data = data;
    }
 
    // CharSequence implementation
    // ---------------------------------------------------------------------------
 
-   public int length()
-   {
+   public int length() {
       return data.length >> 1;
    }
 
-   public char charAt(int pos)
-   {
-      if (pos < 0 || pos >= data.length >> 1)
-      {
+   public char charAt(int pos) {
+      if (pos < 0 || pos >= data.length >> 1) {
          throw new IndexOutOfBoundsException();
       }
       pos <<= 1;
@@ -123,16 +114,13 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
       return (char) ((data[pos] & 0xFF) | (data[pos + 1] << 8) & 0xFF00);
    }
 
-   public CharSequence subSequence(final int start, final int end)
-   {
+   public CharSequence subSequence(final int start, final int end) {
       int len = data.length >> 1;
 
-      if (end < start || start < 0 || end > len)
-      {
+      if (end < start || start < 0 || end > len) {
          throw new IndexOutOfBoundsException();
       }
-      else
-      {
+      else {
          int newlen = end - start << 1;
          byte[] bytes = new byte[newlen];
 
@@ -144,8 +132,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
 
    // Comparable implementation -------------------------------------
 
-   public int compareTo(final SimpleString o)
-   {
+   public int compareTo(final SimpleString o) {
       return toString().compareTo(o.toString());
    }
 
@@ -157,8 +144,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     *
     * @return the byte array
     */
-   public byte[] getData()
-   {
+   public byte[] getData() {
       return data;
    }
 
@@ -168,19 +154,15 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param other the SimpleString to look for
     * @return true if this SimpleString starts with the same data
     */
-   public boolean startsWith(final SimpleString other)
-   {
+   public boolean startsWith(final SimpleString other) {
       byte[] otherdata = other.data;
 
-      if (otherdata.length > data.length)
-      {
+      if (otherdata.length > data.length) {
          return false;
       }
 
-      for (int i = 0; i < otherdata.length; i++)
-      {
-         if (data[i] != otherdata[i])
-         {
+      for (int i = 0; i < otherdata.length; i++) {
+         if (data[i] != otherdata[i]) {
             return false;
          }
       }
@@ -189,18 +171,15 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
    }
 
    @Override
-   public String toString()
-   {
-      if (str == null)
-      {
+   public String toString() {
+      if (str == null) {
          int len = data.length >> 1;
 
          char[] chars = new char[len];
 
          int j = 0;
 
-         for (int i = 0; i < len; i++)
-         {
+         for (int i = 0; i < len; i++) {
             int low = data[j++] & 0xFF;
 
             int high = data[j++] << 8 & 0xFF00;
@@ -215,46 +194,36 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
    }
 
    @Override
-   public boolean equals(final Object other)
-   {
-      if (this == other)
-      {
+   public boolean equals(final Object other) {
+      if (this == other) {
          return true;
       }
 
-      if (other instanceof SimpleString)
-      {
+      if (other instanceof SimpleString) {
          SimpleString s = (SimpleString) other;
 
-         if (data.length != s.data.length)
-         {
+         if (data.length != s.data.length) {
             return false;
          }
 
-         for (int i = 0; i < data.length; i++)
-         {
-            if (data[i] != s.data[i])
-            {
+         for (int i = 0; i < data.length; i++) {
+            if (data[i] != s.data[i]) {
                return false;
             }
          }
 
          return true;
       }
-      else
-      {
+      else {
          return false;
       }
    }
 
    @Override
-   public int hashCode()
-   {
-      if (hash == 0)
-      {
+   public int hashCode() {
+      if (hash == 0) {
          int tmphash = 0;
-         for (byte element : data)
-         {
+         for (byte element : data) {
             tmphash = (tmphash << 5) - tmphash + element; // (hash << 5) - hash is same as hash * 31
          }
          hash = tmphash;
@@ -270,25 +239,21 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param delim The delimiter to split this SimpleString on.
     * @return An array of SimpleStrings
     */
-   public SimpleString[] split(final char delim)
-   {
+   public SimpleString[] split(final char delim) {
       List<SimpleString> all = null;
 
       byte low = (byte) (delim & 0xFF); // low byte
       byte high = (byte) (delim >> 8 & 0xFF); // high byte
 
       int lasPos = 0;
-      for (int i = 0; i < data.length; i += 2)
-      {
-         if (data[i] == low && data[i + 1] == high)
-         {
+      for (int i = 0; i < data.length; i += 2) {
+         if (data[i] == low && data[i + 1] == high) {
             byte[] bytes = new byte[i - lasPos];
             System.arraycopy(data, lasPos, bytes, 0, bytes.length);
             lasPos = i + 2;
 
             // We will create the ArrayList lazily
-            if (all == null)
-            {
+            if (all == null) {
                // There will be at least 2 strings on this case (which is the actual common usecase)
                // For that reason I'm allocating the ArrayList with 2 already
                // I have thought about using LinkedList here but I think this will be good enough already
@@ -299,12 +264,10 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
          }
       }
 
-      if (all == null)
-      {
+      if (all == null) {
          return new SimpleString[]{this};
       }
-      else
-      {
+      else {
          // Adding the last one
          byte[] bytes = new byte[data.length - lasPos];
          System.arraycopy(data, lasPos, bytes, 0, bytes.length);
@@ -322,15 +285,12 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param c the char to check for
     * @return true if the char is found, false otherwise.
     */
-   public boolean contains(final char c)
-   {
+   public boolean contains(final char c) {
       final byte low = (byte) (c & 0xFF); // low byte
       final byte high = (byte) (c >> 8 & 0xFF); // high byte
 
-      for (int i = 0; i < data.length; i += 2)
-      {
-         if (data[i] == low && data[i + 1] == high)
-         {
+      for (int i = 0; i < data.length; i += 2) {
+         if (data[i] == low && data[i + 1] == high) {
             return true;
          }
       }
@@ -343,8 +303,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param toAdd the String to concatenate with.
     * @return the concatenated SimpleString
     */
-   public SimpleString concat(final String toAdd)
-   {
+   public SimpleString concat(final String toAdd) {
       return concat(new SimpleString(toAdd));
    }
 
@@ -354,8 +313,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param toAdd the SimpleString to concatenate with.
     * @return the concatenated SimpleString
     */
-   public SimpleString concat(final SimpleString toAdd)
-   {
+   public SimpleString concat(final SimpleString toAdd) {
       byte[] bytes = new byte[data.length + toAdd.getData().length];
       System.arraycopy(data, 0, bytes, 0, data.length);
       System.arraycopy(toAdd.getData(), 0, bytes, data.length, toAdd.getData().length);
@@ -368,8 +326,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param c the char to concate with.
     * @return the concatenated SimpleString
     */
-   public SimpleString concat(final char c)
-   {
+   public SimpleString concat(final char c) {
       byte[] bytes = new byte[data.length + 2];
       System.arraycopy(data, 0, bytes, 0, data.length);
       bytes[data.length] = (byte) (c & 0xFF);
@@ -382,8 +339,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     *
     * @return the size
     */
-   public int sizeof()
-   {
+   public int sizeof() {
       return DataConstants.SIZE_INT + data.length;
    }
 
@@ -393,8 +349,7 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param str the SimpleString to check
     * @return the size
     */
-   public static int sizeofString(final SimpleString str)
-   {
+   public static int sizeofString(final SimpleString str) {
       return str.sizeof();
    }
 
@@ -404,14 +359,11 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * @param str the SimpleString to check
     * @return the size
     */
-   public static int sizeofNullableString(final SimpleString str)
-   {
-      if (str == null)
-      {
+   public static int sizeofNullableString(final SimpleString str) {
+      if (str == null) {
          return 1;
       }
-      else
-      {
+      else {
          return 1 + str.sizeof();
       }
    }
@@ -421,30 +373,25 @@ public final class SimpleString implements CharSequence, Serializable, Comparabl
     * This is mainly used by the Parsers on Filters
     *
     * @param srcBegin The srcBegin
-    * @param srcEnd The srcEnd
-    * @param dst The destination array
-    * @param dstPos The destination position
+    * @param srcEnd   The srcEnd
+    * @param dst      The destination array
+    * @param dstPos   The destination position
     */
-   public void getChars(final int srcBegin, final int srcEnd, final char[] dst, final int dstPos)
-   {
-      if (srcBegin < 0)
-      {
+   public void getChars(final int srcBegin, final int srcEnd, final char[] dst, final int dstPos) {
+      if (srcBegin < 0) {
          throw new StringIndexOutOfBoundsException(srcBegin);
       }
-      if (srcEnd > length())
-      {
+      if (srcEnd > length()) {
          throw new StringIndexOutOfBoundsException(srcEnd);
       }
-      if (srcBegin > srcEnd)
-      {
+      if (srcBegin > srcEnd) {
          throw new StringIndexOutOfBoundsException(srcEnd - srcBegin);
       }
 
       int j = srcBegin * 2;
       int d = dstPos;
 
-      for (int i = srcBegin; i < srcEnd; i++)
-      {
+      for (int i = srcBegin; i < srcEnd; i++) {
          int low = data[j++] & 0xFF;
 
          int high = data[j++] << 8 & 0xFF00;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
index bb45cb7..51fea91 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
@@ -25,16 +25,14 @@ import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.utils.DataConstants;
 import org.apache.activemq.artemis.utils.UTF8Util;
 
-public class ChannelBufferWrapper implements ActiveMQBuffer
-{
+public class ChannelBufferWrapper implements ActiveMQBuffer {
+
    protected ByteBuf buffer; // NO_UCD (use final)
    private final boolean releasable;
 
-   public static ByteBuf unwrap(ByteBuf buffer)
-   {
+   public static ByteBuf unwrap(ByteBuf buffer) {
       ByteBuf parent;
-      while ((parent = buffer.unwrap()) != null &&
-              parent != buffer) // this last part is just in case the semantic
+      while ((parent = buffer.unwrap()) != null && parent != buffer) // this last part is just in case the semantic
       {                         // ever changes where unwrap is returning itself
          buffer = parent;
       }
@@ -42,591 +40,473 @@ public class ChannelBufferWrapper implements ActiveMQBuffer
       return buffer;
    }
 
-   public ChannelBufferWrapper(final ByteBuf buffer)
-   {
+   public ChannelBufferWrapper(final ByteBuf buffer) {
       this(buffer, false);
    }
 
-   public ChannelBufferWrapper(final ByteBuf buffer, boolean releasable)
-   {
-      if (!releasable)
-      {
+   public ChannelBufferWrapper(final ByteBuf buffer, boolean releasable) {
+      if (!releasable) {
          this.buffer = Unpooled.unreleasableBuffer(buffer);
       }
-      else
-      {
+      else {
          this.buffer = buffer;
       }
       this.releasable = releasable;
    }
 
-   public boolean readBoolean()
-   {
+   public boolean readBoolean() {
       return readByte() != 0;
    }
 
-   public SimpleString readNullableSimpleString()
-   {
+   public SimpleString readNullableSimpleString() {
       int b = buffer.readByte();
-      if (b == DataConstants.NULL)
-      {
+      if (b == DataConstants.NULL) {
          return null;
       }
       return readSimpleStringInternal();
    }
 
-   public String readNullableString()
-   {
+   public String readNullableString() {
       int b = buffer.readByte();
-      if (b == DataConstants.NULL)
-      {
+      if (b == DataConstants.NULL) {
          return null;
       }
       return readStringInternal();
    }
 
-   public SimpleString readSimpleString()
-   {
+   public SimpleString readSimpleString() {
       return readSimpleStringInternal();
    }
 
-   private SimpleString readSimpleStringInternal()
-   {
+   private SimpleString readSimpleStringInternal() {
       int len = buffer.readInt();
       byte[] data = new byte[len];
       buffer.readBytes(data);
       return new SimpleString(data);
    }
 
-   public String readString()
-   {
+   public String readString() {
       return readStringInternal();
    }
 
-   private String readStringInternal()
-   {
+   private String readStringInternal() {
       int len = buffer.readInt();
 
-      if (len < 9)
-      {
+      if (len < 9) {
          char[] chars = new char[len];
-         for (int i = 0; i < len; i++)
-         {
-            chars[i] = (char)buffer.readShort();
+         for (int i = 0; i < len; i++) {
+            chars[i] = (char) buffer.readShort();
          }
          return new String(chars);
       }
-      else if (len < 0xfff)
-      {
+      else if (len < 0xfff) {
          return readUTF();
       }
-      else
-      {
+      else {
          return readSimpleStringInternal().toString();
       }
    }
 
-   public String readUTF()
-   {
+   public String readUTF() {
       return UTF8Util.readUTF(this);
    }
 
-   public void writeBoolean(final boolean val)
-   {
-      buffer.writeByte((byte)(val ? -1 : 0));
+   public void writeBoolean(final boolean val) {
+      buffer.writeByte((byte) (val ? -1 : 0));
    }
 
-   public void writeNullableSimpleString(final SimpleString val)
-   {
-      if (val == null)
-      {
+   public void writeNullableSimpleString(final SimpleString val) {
+      if (val == null) {
          buffer.writeByte(DataConstants.NULL);
       }
-      else
-      {
+      else {
          buffer.writeByte(DataConstants.NOT_NULL);
          writeSimpleStringInternal(val);
       }
    }
 
-   public void writeNullableString(final String val)
-   {
-      if (val == null)
-      {
+   public void writeNullableString(final String val) {
+      if (val == null) {
          buffer.writeByte(DataConstants.NULL);
       }
-      else
-      {
+      else {
          buffer.writeByte(DataConstants.NOT_NULL);
          writeStringInternal(val);
       }
    }
 
-   public void writeSimpleString(final SimpleString val)
-   {
+   public void writeSimpleString(final SimpleString val) {
       writeSimpleStringInternal(val);
    }
 
-   private void writeSimpleStringInternal(final SimpleString val)
-   {
+   private void writeSimpleStringInternal(final SimpleString val) {
       byte[] data = val.getData();
       buffer.writeInt(data.length);
       buffer.writeBytes(data);
    }
 
-   public void writeString(final String val)
-   {
+   public void writeString(final String val) {
       writeStringInternal(val);
    }
 
-   private void writeStringInternal(final String val)
-   {
+   private void writeStringInternal(final String val) {
       int length = val.length();
 
       buffer.writeInt(length);
 
-      if (length < 9)
-      {
+      if (length < 9) {
          // If very small it's more performant to store char by char
-         for (int i = 0; i < val.length(); i++)
-         {
-            buffer.writeShort((short)val.charAt(i));
+         for (int i = 0; i < val.length(); i++) {
+            buffer.writeShort((short) val.charAt(i));
          }
       }
-      else if (length < 0xfff)
-      {
+      else if (length < 0xfff) {
          // Store as UTF - this is quicker than char by char for most strings
          writeUTF(val);
       }
-      else
-      {
+      else {
          // Store as SimpleString, since can't store utf > 0xffff in length
          writeSimpleStringInternal(new SimpleString(val));
       }
    }
 
-   public void writeUTF(final String utf)
-   {
+   public void writeUTF(final String utf) {
       UTF8Util.saveUTF(this, utf);
    }
 
-   public int capacity()
-   {
+   public int capacity() {
       return buffer.capacity();
    }
 
-   public ByteBuf byteBuf()
-   {
+   public ByteBuf byteBuf() {
       return buffer;
    }
 
-   public void clear()
-   {
+   public void clear() {
       buffer.clear();
    }
 
-   public ActiveMQBuffer copy()
-   {
+   public ActiveMQBuffer copy() {
       return new ChannelBufferWrapper(buffer.copy(), releasable);
    }
 
-   public ActiveMQBuffer copy(final int index, final int length)
-   {
+   public ActiveMQBuffer copy(final int index, final int length) {
       return new ChannelBufferWrapper(buffer.copy(index, length), releasable);
    }
 
-   public void discardReadBytes()
-   {
+   public void discardReadBytes() {
       buffer.discardReadBytes();
    }
 
-   public ActiveMQBuffer duplicate()
-   {
+   public ActiveMQBuffer duplicate() {
       return new ChannelBufferWrapper(buffer.duplicate(), releasable);
    }
 
-   public byte getByte(final int index)
-   {
+   public byte getByte(final int index) {
       return buffer.getByte(index);
    }
 
-   public void getBytes(final int index, final byte[] dst, final int dstIndex, final int length)
-   {
+   public void getBytes(final int index, final byte[] dst, final int dstIndex, final int length) {
       buffer.getBytes(index, dst, dstIndex, length);
    }
 
-   public void getBytes(final int index, final byte[] dst)
-   {
+   public void getBytes(final int index, final byte[] dst) {
       buffer.getBytes(index, dst);
    }
 
-   public void getBytes(final int index, final ByteBuffer dst)
-   {
+   public void getBytes(final int index, final ByteBuffer dst) {
       buffer.getBytes(index, dst);
    }
 
-   public void getBytes(final int index, final ActiveMQBuffer dst, final int dstIndex, final int length)
-   {
+   public void getBytes(final int index, final ActiveMQBuffer dst, final int dstIndex, final int length) {
       buffer.getBytes(index, dst.byteBuf(), dstIndex, length);
    }
 
-   public void getBytes(final int index, final ActiveMQBuffer dst, final int length)
-   {
+   public void getBytes(final int index, final ActiveMQBuffer dst, final int length) {
       buffer.getBytes(index, dst.byteBuf(), length);
    }
 
-   public void getBytes(final int index, final ActiveMQBuffer dst)
-   {
+   public void getBytes(final int index, final ActiveMQBuffer dst) {
       buffer.getBytes(index, dst.byteBuf());
    }
 
-   public char getChar(final int index)
-   {
-      return (char)buffer.getShort(index);
+   public char getChar(final int index) {
+      return (char) buffer.getShort(index);
    }
 
-   public double getDouble(final int index)
-   {
+   public double getDouble(final int index) {
       return Double.longBitsToDouble(buffer.getLong(index));
    }
 
-   public float getFloat(final int index)
-   {
+   public float getFloat(final int index) {
       return Float.intBitsToFloat(buffer.getInt(index));
    }
 
-   public int getInt(final int index)
-   {
+   public int getInt(final int index) {
       return buffer.getInt(index);
    }
 
-   public long getLong(final int index)
-   {
+   public long getLong(final int index) {
       return buffer.getLong(index);
    }
 
-   public short getShort(final int index)
-   {
+   public short getShort(final int index) {
       return buffer.getShort(index);
    }
 
-   public short getUnsignedByte(final int index)
-   {
+   public short getUnsignedByte(final int index) {
       return buffer.getUnsignedByte(index);
    }
 
-   public long getUnsignedInt(final int index)
-   {
+   public long getUnsignedInt(final int index) {
       return buffer.getUnsignedInt(index);
    }
 
-   public int getUnsignedShort(final int index)
-   {
+   public int getUnsignedShort(final int index) {
       return buffer.getUnsignedShort(index);
    }
 
-   public void markReaderIndex()
-   {
+   public void markReaderIndex() {
       buffer.markReaderIndex();
    }
 
-   public void markWriterIndex()
-   {
+   public void markWriterIndex() {
       buffer.markWriterIndex();
    }
 
-   public boolean readable()
-   {
+   public boolean readable() {
       return buffer.isReadable();
    }
 
-   public int readableBytes()
-   {
+   public int readableBytes() {
       return buffer.readableBytes();
    }
 
-   public byte readByte()
-   {
+   public byte readByte() {
       return buffer.readByte();
    }
 
-   public void readBytes(final byte[] dst, final int dstIndex, final int length)
-   {
+   public void readBytes(final byte[] dst, final int dstIndex, final int length) {
       buffer.readBytes(dst, dstIndex, length);
    }
 
-   public void readBytes(final byte[] dst)
-   {
+   public void readBytes(final byte[] dst) {
       buffer.readBytes(dst);
    }
 
-   public void readBytes(final ByteBuffer dst)
-   {
+   public void readBytes(final ByteBuffer dst) {
       buffer.readBytes(dst);
    }
 
-   public void readBytes(final ActiveMQBuffer dst, final int dstIndex, final int length)
-   {
+   public void readBytes(final ActiveMQBuffer dst, final int dstIndex, final int length) {
       buffer.readBytes(dst.byteBuf(), dstIndex, length);
    }
 
-   public void readBytes(final ActiveMQBuffer dst, final int length)
-   {
+   public void readBytes(final ActiveMQBuffer dst, final int length) {
       buffer.readBytes(dst.byteBuf(), length);
    }
 
-   public void readBytes(final ActiveMQBuffer dst)
-   {
+   public void readBytes(final ActiveMQBuffer dst) {
       buffer.readBytes(dst.byteBuf());
    }
 
-   public ActiveMQBuffer readBytes(final int length)
-   {
+   public ActiveMQBuffer readBytes(final int length) {
       return new ChannelBufferWrapper(buffer.readBytes(length), releasable);
    }
 
-   public char readChar()
-   {
-      return (char)buffer.readShort();
+   public char readChar() {
+      return (char) buffer.readShort();
    }
 
-   public double readDouble()
-   {
+   public double readDouble() {
       return Double.longBitsToDouble(buffer.readLong());
    }
 
-   public int readerIndex()
-   {
+   public int readerIndex() {
       return buffer.readerIndex();
    }
 
-   public void readerIndex(final int readerIndex)
-   {
+   public void readerIndex(final int readerIndex) {
       buffer.readerIndex(readerIndex);
    }
 
-   public float readFloat()
-   {
+   public float readFloat() {
       return Float.intBitsToFloat(buffer.readInt());
    }
 
-   public int readInt()
-   {
+   public int readInt() {
       return buffer.readInt();
    }
 
-   public long readLong()
-   {
+   public long readLong() {
       return buffer.readLong();
    }
 
-   public short readShort()
-   {
+   public short readShort() {
       return buffer.readShort();
    }
 
-   public ActiveMQBuffer readSlice(final int length)
-   {
+   public ActiveMQBuffer readSlice(final int length) {
       return new ChannelBufferWrapper(buffer.readSlice(length), releasable);
    }
 
-   public short readUnsignedByte()
-   {
+   public short readUnsignedByte() {
       return buffer.readUnsignedByte();
    }
 
-   public long readUnsignedInt()
-   {
+   public long readUnsignedInt() {
       return buffer.readUnsignedInt();
    }
 
-   public int readUnsignedShort()
-   {
+   public int readUnsignedShort() {
       return buffer.readUnsignedShort();
    }
 
-   public void resetReaderIndex()
-   {
+   public void resetReaderIndex() {
       buffer.resetReaderIndex();
    }
 
-   public void resetWriterIndex()
-   {
+   public void resetWriterIndex() {
       buffer.resetWriterIndex();
    }
 
-   public void setByte(final int index, final byte value)
-   {
+   public void setByte(final int index, final byte value) {
       buffer.setByte(index, value);
    }
 
-   public void setBytes(final int index, final byte[] src, final int srcIndex, final int length)
-   {
+   public void setBytes(final int index, final byte[] src, final int srcIndex, final int length) {
       buffer.setBytes(index, src, srcIndex, length);
    }
 
-   public void setBytes(final int index, final byte[] src)
-   {
+   public void setBytes(final int index, final byte[] src) {
       buffer.setBytes(index, src);
    }
 
-   public void setBytes(final int index, final ByteBuffer src)
-   {
+   public void setBytes(final int index, final ByteBuffer src) {
       buffer.setBytes(index, src);
    }
 
-   public void setBytes(final int index, final ActiveMQBuffer src, final int srcIndex, final int length)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src, final int srcIndex, final int length) {
       buffer.setBytes(index, src.byteBuf(), srcIndex, length);
    }
 
-   public void setBytes(final int index, final ActiveMQBuffer src, final int length)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src, final int length) {
       buffer.setBytes(index, src.byteBuf(), length);
    }
 
-   public void setBytes(final int index, final ActiveMQBuffer src)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src) {
       buffer.setBytes(index, src.byteBuf());
    }
 
-   public void setChar(final int index, final char value)
-   {
-      buffer.setShort(index, (short)value);
+   public void setChar(final int index, final char value) {
+      buffer.setShort(index, (short) value);
    }
 
-   public void setDouble(final int index, final double value)
-   {
+   public void setDouble(final int index, final double value) {
       buffer.setLong(index, Double.doubleToLongBits(value));
    }
 
-   public void setFloat(final int index, final float value)
-   {
+   public void setFloat(final int index, final float value) {
       buffer.setInt(index, Float.floatToIntBits(value));
    }
 
-   public void setIndex(final int readerIndex, final int writerIndex)
-   {
+   public void setIndex(final int readerIndex, final int writerIndex) {
       buffer.setIndex(readerIndex, writerIndex);
    }
 
-   public void setInt(final int index, final int value)
-   {
+   public void setInt(final int index, final int value) {
       buffer.setInt(index, value);
    }
 
-   public void setLong(final int index, final long value)
-   {
+   public void setLong(final int index, final long value) {
       buffer.setLong(index, value);
    }
 
-   public void setShort(final int index, final short value)
-   {
+   public void setShort(final int index, final short value) {
       buffer.setShort(index, value);
    }
 
-   public void skipBytes(final int length)
-   {
+   public void skipBytes(final int length) {
       buffer.skipBytes(length);
    }
 
-   public ActiveMQBuffer slice()
-   {
+   public ActiveMQBuffer slice() {
       return new ChannelBufferWrapper(buffer.slice(), releasable);
    }
 
-   public ActiveMQBuffer slice(final int index, final int length)
-   {
+   public ActiveMQBuffer slice(final int index, final int length) {
       return new ChannelBufferWrapper(buffer.slice(index, length), releasable);
    }
 
-   public ByteBuffer toByteBuffer()
-   {
+   public ByteBuffer toByteBuffer() {
       return buffer.nioBuffer();
    }
 
-   public ByteBuffer toByteBuffer(final int index, final int length)
-   {
+   public ByteBuffer toByteBuffer(final int index, final int length) {
       return buffer.nioBuffer(index, length);
    }
 
-   public boolean writable()
-   {
+   public boolean writable() {
       return buffer.isWritable();
    }
 
-   public int writableBytes()
-   {
+   public int writableBytes() {
       return buffer.writableBytes();
    }
 
-   public void writeByte(final byte value)
-   {
+   public void writeByte(final byte value) {
       buffer.writeByte(value);
    }
 
-   public void writeBytes(final byte[] src, final int srcIndex, final int length)
-   {
+   public void writeBytes(final byte[] src, final int srcIndex, final int length) {
       buffer.writeBytes(src, srcIndex, length);
    }
 
-   public void writeBytes(final byte[] src)
-   {
+   public void writeBytes(final byte[] src) {
       buffer.writeBytes(src);
    }
 
-   public void writeBytes(final ByteBuffer src)
-   {
+   public void writeBytes(final ByteBuffer src) {
       buffer.writeBytes(src);
    }
 
-   public void writeBytes(final ActiveMQBuffer src, final int srcIndex, final int length)
-   {
+   public void writeBytes(final ActiveMQBuffer src, final int srcIndex, final int length) {
       buffer.writeBytes(src.byteBuf(), srcIndex, length);
    }
 
-   public void writeBytes(final ActiveMQBuffer src, final int length)
-   {
+   public void writeBytes(final ActiveMQBuffer src, final int length) {
       buffer.writeBytes(src.byteBuf(), length);
    }
 
-   public void writeChar(final char chr)
-   {
-      buffer.writeShort((short)chr);
+   public void writeChar(final char chr) {
+      buffer.writeShort((short) chr);
    }
 
-   public void writeDouble(final double value)
-   {
+   public void writeDouble(final double value) {
       buffer.writeLong(Double.doubleToLongBits(value));
    }
 
-   public void writeFloat(final float value)
-   {
+   public void writeFloat(final float value) {
       buffer.writeInt(Float.floatToIntBits(value));
    }
 
-   public void writeInt(final int value)
-   {
+   public void writeInt(final int value) {
       buffer.writeInt(value);
    }
 
-   public void writeLong(final long value)
-   {
+   public void writeLong(final long value) {
       buffer.writeLong(value);
    }
 
-   public int writerIndex()
-   {
+   public int writerIndex() {
       return buffer.writerIndex();
    }
 
-   public void writerIndex(final int writerIndex)
-   {
+   public void writerIndex(final int writerIndex) {
       buffer.writerIndex(writerIndex);
    }
 
-   public void writeShort(final short value)
-   {
+   public void writeShort(final short value) {
       buffer.writeShort(value);
    }
 


Mime
View raw message