activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [18/20] activemq-6 git commit: ACTIVEMQ6-3 Renaming Exception classes and fixing native compilation
Date Tue, 18 Nov 2014 09:24:20 GMT
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQConnectionTimedOutException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQConnectionTimedOutException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQConnectionTimedOutException.java
new file mode 100644
index 0000000..88c39c3
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQConnectionTimedOutException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.CONNECTION_TIMEDOUT;
+
+/**
+ * A client timed out will connecting to HornetQ server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQConnectionTimedOutException extends ActiveMQException
+{
+   private static final long serialVersionUID = 3244233758084830372L;
+
+   public ActiveMQConnectionTimedOutException()
+   {
+      super(CONNECTION_TIMEDOUT);
+   }
+
+   public ActiveMQConnectionTimedOutException(String msg)
+   {
+      super(CONNECTION_TIMEDOUT, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDisconnectedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDisconnectedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDisconnectedException.java
new file mode 100644
index 0000000..038472c
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDisconnectedException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.DISCONNECTED;
+
+/**
+ * A client was disconnected from HornetQ server when the server has shut down.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQDisconnectedException extends ActiveMQException
+{
+   private static final long serialVersionUID = 7414966383933311627L;
+
+   public ActiveMQDisconnectedException()
+   {
+      super(DISCONNECTED);
+   }
+
+   public ActiveMQDisconnectedException(String message)
+   {
+      super(DISCONNECTED, message);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateIdException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateIdException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateIdException.java
new file mode 100644
index 0000000..93731da
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateIdException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.DUPLICATE_ID_REJECTED;
+
+/**
+ * A DuplicateID was rejected.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQDuplicateIdException extends ActiveMQException
+{
+   private static final long serialVersionUID = -4302979339865777119L;
+
+   public ActiveMQDuplicateIdException()
+   {
+      super(DUPLICATE_ID_REJECTED);
+   }
+
+   public ActiveMQDuplicateIdException(String message)
+   {
+      super(DUPLICATE_ID_REJECTED, message);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateMetaDataException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateMetaDataException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateMetaDataException.java
new file mode 100644
index 0000000..17fec0a
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQDuplicateMetaDataException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.DUPLICATE_METADATA;
+
+/**
+ * A Session Metadata was set in duplication
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQDuplicateMetaDataException extends ActiveMQException
+{
+   private static final long serialVersionUID = 7877182872143004058L;
+
+   public ActiveMQDuplicateMetaDataException()
+   {
+      super(DUPLICATE_METADATA);
+   }
+
+   public ActiveMQDuplicateMetaDataException(String msg)
+   {
+      super(DUPLICATE_METADATA, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQException.java
new file mode 100644
index 0000000..6165617
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQException.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq.api.core;
+
+/**
+ * ActiveMQException is the root exception for the ActiveMQ API.
+ * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
+ */
+public class ActiveMQException extends Exception
+{
+   private static final long serialVersionUID = -4802014152804997417L;
+
+   private final ActiveMQExceptionType type;
+
+   public ActiveMQException()
+   {
+      type = ActiveMQExceptionType.GENERIC_EXCEPTION;
+   }
+
+   public ActiveMQException(final String msg)
+   {
+      super(msg);
+      type = ActiveMQExceptionType.GENERIC_EXCEPTION;
+   }
+
+   /*
+   * This constructor is needed only for the native layer
+   */
+   public ActiveMQException(int code, String msg)
+   {
+      super(msg);
+
+      this.type = ActiveMQExceptionType.getType(code);
+   }
+
+   public ActiveMQException(ActiveMQExceptionType type, String msg)
+   {
+      super(msg);
+
+      this.type = type;
+   }
+
+   public ActiveMQException(ActiveMQExceptionType type)
+   {
+      this.type = type;
+   }
+
+   public ActiveMQException(ActiveMQExceptionType type, String message, Throwable t)
+   {
+      super(message, t);
+      this.type = type;
+   }
+
+   public ActiveMQExceptionType getType()
+   {
+      return type;
+   }
+
+   @Override
+   public String toString()
+   {
+      return this.getClass().getSimpleName() + "[errorType=" + type + " message=" + getMessage() + "]";
+   }
+
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQExceptionType.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQExceptionType.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQExceptionType.java
new file mode 100644
index 0000000..5e459ec
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQExceptionType.java
@@ -0,0 +1,298 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq.api.core;
+
+import java.util.Collections;
+import java.util.EnumSet;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Defines all {@link ActiveMQException} types and their codes.
+ */
+public enum ActiveMQExceptionType
+{
+
+   // Error codes -------------------------------------------------
+
+   INTERNAL_ERROR(000)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQInternalErrorException(msg);
+      }
+   },
+   UNSUPPORTED_PACKET(001)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQUnsupportedPacketException(msg);
+      }
+   },
+   NOT_CONNECTED(002)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQNotConnectedException(msg);
+      }
+   },
+   CONNECTION_TIMEDOUT(003)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQConnectionTimedOutException(msg);
+      }
+   },
+   DISCONNECTED(004)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQDisconnectedException(msg);
+      }
+   },
+   UNBLOCKED(005)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQUnBlockedException(msg);
+      }
+   },
+   IO_ERROR(006)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQIOErrorException(msg);
+      }
+   },
+   QUEUE_DOES_NOT_EXIST(100)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQNonExistentQueueException(msg);
+      }
+   },
+   QUEUE_EXISTS(101)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQQueueExistsException(msg);
+      }
+   },
+   OBJECT_CLOSED(102)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQObjectClosedException(msg);
+      }
+   },
+   INVALID_FILTER_EXPRESSION(103)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQInvalidFilterExpressionException(msg);
+      }
+   },
+   ILLEGAL_STATE(104)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQIllegalStateException(msg);
+      }
+   },
+   SECURITY_EXCEPTION(105)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQSecurityException(msg);
+      }
+   },
+   ADDRESS_EXISTS(107)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQAddressExistsException(msg);
+      }
+   },
+   INCOMPATIBLE_CLIENT_SERVER_VERSIONS(108)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQIncompatibleClientServerException(msg);
+      }
+   },
+   LARGE_MESSAGE_ERROR_BODY(110)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQLargeMessageException(msg);
+      }
+   },
+   TRANSACTION_ROLLED_BACK(111)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQTransactionRolledBackException(msg);
+      }
+   },
+   SESSION_CREATION_REJECTED(112)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQSessionCreationException(msg);
+      }
+   },
+   DUPLICATE_ID_REJECTED(113)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQDuplicateIdException(msg);
+      }
+   },
+   DUPLICATE_METADATA(114)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQDuplicateMetaDataException(msg);
+      }
+   },
+   TRANSACTION_OUTCOME_UNKNOWN(115)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQTransactionOutcomeUnknownException(msg);
+      }
+   },
+   ALREADY_REPLICATING(116)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQAlreadyReplicatingException(msg);
+      }
+   },
+   INTERCEPTOR_REJECTED_PACKET(117)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQInterceptorRejectedPacketException(msg);
+      }
+   },
+   INVALID_TRANSIENT_QUEUE_USE(118)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQInvalidTransientQueueUseException(msg);
+      }
+   },
+
+   GENERIC_EXCEPTION(999),
+   NATIVE_ERROR_INTERNAL(200),
+   NATIVE_ERROR_INVALID_BUFFER(201),
+   NATIVE_ERROR_NOT_ALIGNED(202),
+   NATIVE_ERROR_CANT_INITIALIZE_AIO(203),
+   NATIVE_ERROR_CANT_RELEASE_AIO(204),
+   NATIVE_ERROR_CANT_OPEN_CLOSE_FILE(205),
+   NATIVE_ERROR_CANT_ALLOCATE_QUEUE(206),
+   NATIVE_ERROR_PREALLOCATE_FILE(208),
+   NATIVE_ERROR_ALLOCATE_MEMORY(209),
+   ADDRESS_FULL(210)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQAddressFullException(msg);
+      }
+   },
+   LARGE_MESSAGE_INTERRUPTED(211)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQLargeMessageInterruptedException(msg);
+      }
+   },
+   CLUSTER_SECURITY_EXCEPTION(212)
+   {
+      @Override
+      public ActiveMQException createException(String msg)
+      {
+         return new ActiveMQClusterSecurityException(msg);
+      }
+
+   };
+
+   private static final Map<Integer, ActiveMQExceptionType> TYPE_MAP;
+
+   static
+   {
+      HashMap<Integer, ActiveMQExceptionType> map = new HashMap<Integer, ActiveMQExceptionType>();
+      for (ActiveMQExceptionType type : EnumSet.allOf(ActiveMQExceptionType.class))
+      {
+         map.put(type.getCode(), type);
+      }
+      TYPE_MAP = Collections.unmodifiableMap(map);
+   }
+
+   private final int code;
+
+   ActiveMQExceptionType(int code)
+   {
+      this.code = code;
+   }
+
+   public int getCode()
+   {
+      return code;
+   }
+
+   public ActiveMQException createException(String msg)
+   {
+      return new ActiveMQException(msg + ", code:" + this);
+   }
+
+   public static ActiveMQException createException(int code, String msg)
+   {
+      return getType(code).createException(msg);
+   }
+
+   public static ActiveMQExceptionType getType(int code)
+   {
+      ActiveMQExceptionType type = TYPE_MAP.get(code);
+      if (type != null)
+         return type;
+      return ActiveMQExceptionType.GENERIC_EXCEPTION;
+   }
+}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIOErrorException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIOErrorException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIOErrorException.java
new file mode 100644
index 0000000..032b39a
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIOErrorException.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.IO_ERROR;
+
+/**
+ * Unexpected I/O error occurred on the server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQIOErrorException extends ActiveMQException
+{
+   private static final long serialVersionUID = 797277117077787396L;
+
+   public ActiveMQIOErrorException()
+   {
+      super(IO_ERROR);
+   }
+
+   public ActiveMQIOErrorException(String msg)
+   {
+      super(IO_ERROR, msg);
+   }
+
+   public ActiveMQIOErrorException(String msg, Throwable cause)
+   {
+      super(IO_ERROR, msg, cause);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIllegalStateException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIllegalStateException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIllegalStateException.java
new file mode 100644
index 0000000..2dd437f
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIllegalStateException.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.ILLEGAL_STATE;
+
+/**
+ * A HornetQ resource is not in a legal state (e.g. calling ClientConsumer.receive() if a
+ * MessageHandler is set).
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQIllegalStateException extends ActiveMQException
+{
+   private static final long serialVersionUID = -4480125401057788511L;
+
+   public ActiveMQIllegalStateException()
+   {
+      super(ILLEGAL_STATE);
+   }
+
+   public ActiveMQIllegalStateException(String message)
+   {
+      super(ILLEGAL_STATE, message);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIncompatibleClientServerException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIncompatibleClientServerException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIncompatibleClientServerException.java
new file mode 100644
index 0000000..a83c2bb
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQIncompatibleClientServerException.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.INCOMPATIBLE_CLIENT_SERVER_VERSIONS;
+
+/**
+ * The server version and the client version are incompatible.
+ * <p>
+ * Normally this means you are trying to use a newer client on an older server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
+ */
+public final class ActiveMQIncompatibleClientServerException extends ActiveMQException
+{
+   private static final long serialVersionUID = -1662999230291452298L;
+
+   public ActiveMQIncompatibleClientServerException()
+   {
+      super(INCOMPATIBLE_CLIENT_SERVER_VERSIONS);
+   }
+
+   public ActiveMQIncompatibleClientServerException(String msg)
+   {
+      super(INCOMPATIBLE_CLIENT_SERVER_VERSIONS, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterceptorRejectedPacketException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterceptorRejectedPacketException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterceptorRejectedPacketException.java
new file mode 100644
index 0000000..aae32a7
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterceptorRejectedPacketException.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.INTERCEPTOR_REJECTED_PACKET;
+
+/**
+ * An outgoing interceptor returned false.
+ * @see org.apache.activemq.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq.api.core.Interceptor)
+ * @author Justin Bertram
+ */
+// XXX I doubt any reader will make much sense of this Javadoc's text.
+public final class ActiveMQInterceptorRejectedPacketException extends ActiveMQException
+{
+   private static final long serialVersionUID = -5798841227645281815L;
+
+   public ActiveMQInterceptorRejectedPacketException()
+   {
+      super(INTERCEPTOR_REJECTED_PACKET);
+   }
+
+   public ActiveMQInterceptorRejectedPacketException(String msg)
+   {
+      super(INTERCEPTOR_REJECTED_PACKET, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInternalErrorException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInternalErrorException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInternalErrorException.java
new file mode 100644
index 0000000..691b288
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInternalErrorException.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.INTERNAL_ERROR;
+
+/**
+ * Internal error which prevented HornetQ from performing an important operation.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQInternalErrorException extends ActiveMQException
+{
+   private static final long serialVersionUID = -5987814047521530695L;
+
+   public ActiveMQInternalErrorException()
+   {
+      super(INTERNAL_ERROR);
+   }
+
+   public ActiveMQInternalErrorException(String msg)
+   {
+      super(INTERNAL_ERROR, msg);
+   }
+
+   public ActiveMQInternalErrorException(String message, Exception e)
+   {
+      super(INTERNAL_ERROR, message, e);
+   }
+
+   public ActiveMQInternalErrorException(String message, Throwable t)
+   {
+      super(INTERNAL_ERROR, message, t);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterruptedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterruptedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterruptedException.java
new file mode 100644
index 0000000..0b39527
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInterruptedException.java
@@ -0,0 +1,27 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq.api.core;
+
+/**
+ * When an interruption happens, we will just throw a non-checked exception.
+ * @author clebertsuconic
+ */
+public final class ActiveMQInterruptedException extends RuntimeException
+{
+   private static final long serialVersionUID = -5744690023549671221L;
+
+   public ActiveMQInterruptedException(Throwable cause)
+   {
+      super(cause);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidFilterExpressionException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidFilterExpressionException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidFilterExpressionException.java
new file mode 100644
index 0000000..b7f9738
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidFilterExpressionException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.INVALID_FILTER_EXPRESSION;
+
+/**
+ * A filter expression was found to be invalid.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQInvalidFilterExpressionException extends ActiveMQException
+{
+   private static final long serialVersionUID = 7188625553939665128L;
+
+   public ActiveMQInvalidFilterExpressionException()
+   {
+      super(INVALID_FILTER_EXPRESSION);
+   }
+
+   public ActiveMQInvalidFilterExpressionException(String msg)
+   {
+      super(INVALID_FILTER_EXPRESSION, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidTransientQueueUseException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidTransientQueueUseException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidTransientQueueUseException.java
new file mode 100644
index 0000000..3ce3634
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQInvalidTransientQueueUseException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.INVALID_TRANSIENT_QUEUE_USE;
+
+/**
+ * An operation failed because a queue exists on the server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQInvalidTransientQueueUseException extends ActiveMQException
+{
+   private static final long serialVersionUID = -405552292451883063L;
+
+   public ActiveMQInvalidTransientQueueUseException()
+   {
+      super(INVALID_TRANSIENT_QUEUE_USE);
+   }
+
+   public ActiveMQInvalidTransientQueueUseException(String msg)
+   {
+      super(INVALID_TRANSIENT_QUEUE_USE, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageException.java
new file mode 100644
index 0000000..b9758e6
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.LARGE_MESSAGE_ERROR_BODY;
+
+/**
+ * A problem occurred while manipulating the body of a large message.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQLargeMessageException extends ActiveMQException
+{
+   private static final long serialVersionUID = 1087867463974768491L;
+
+   public ActiveMQLargeMessageException()
+   {
+      super(LARGE_MESSAGE_ERROR_BODY);
+   }
+
+   public ActiveMQLargeMessageException(String msg)
+   {
+      super(LARGE_MESSAGE_ERROR_BODY, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageInterruptedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageInterruptedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageInterruptedException.java
new file mode 100644
index 0000000..9d69cfb
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQLargeMessageInterruptedException.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.LARGE_MESSAGE_INTERRUPTED;
+
+/**
+ * @author Clebert
+ */
+// XXX
+public class ActiveMQLargeMessageInterruptedException extends ActiveMQException
+{
+   private static final long serialVersionUID = 0;
+
+   public ActiveMQLargeMessageInterruptedException(String message)
+   {
+      super(LARGE_MESSAGE_INTERRUPTED, message);
+   }
+
+   public ActiveMQLargeMessageInterruptedException()
+   {
+      super(LARGE_MESSAGE_INTERRUPTED);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNativeIOError.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNativeIOError.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNativeIOError.java
new file mode 100644
index 0000000..c1697df
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNativeIOError.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+
+/**
+ * An error has happened at HornetQ's native (non-Java) code used in reading and writing data.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/4/12
+ */
+// XXX
+public final class ActiveMQNativeIOError extends ActiveMQException
+{
+   private static final long serialVersionUID = 2355120980683293085L;
+
+   public ActiveMQNativeIOError()
+   {
+      super(ActiveMQExceptionType.NATIVE_ERROR_CANT_INITIALIZE_AIO);
+   }
+
+   public ActiveMQNativeIOError(String msg)
+   {
+      super(ActiveMQExceptionType.NATIVE_ERROR_CANT_INITIALIZE_AIO, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNonExistentQueueException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNonExistentQueueException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNonExistentQueueException.java
new file mode 100644
index 0000000..86d3e55
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNonExistentQueueException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.QUEUE_DOES_NOT_EXIST;
+
+/**
+ * An operation failed because a queue does not exist on the server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQNonExistentQueueException extends ActiveMQException
+{
+   private static final long serialVersionUID = -8199298881947523607L;
+
+   public ActiveMQNonExistentQueueException()
+   {
+      super(QUEUE_DOES_NOT_EXIST);
+   }
+
+   public ActiveMQNonExistentQueueException(String msg)
+   {
+      super(QUEUE_DOES_NOT_EXIST, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNotConnectedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNotConnectedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNotConnectedException.java
new file mode 100644
index 0000000..0b6e99c
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQNotConnectedException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.NOT_CONNECTED;
+
+/**
+ * A client is not able to connect to HornetQ server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQNotConnectedException extends ActiveMQException
+{
+   private static final long serialVersionUID = -3489189971813613325L;
+
+   public ActiveMQNotConnectedException(String message)
+   {
+      super(NOT_CONNECTED, message);
+   }
+
+   public ActiveMQNotConnectedException()
+   {
+      super(NOT_CONNECTED);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQObjectClosedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQObjectClosedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQObjectClosedException.java
new file mode 100644
index 0000000..87898b7
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQObjectClosedException.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.OBJECT_CLOSED;
+
+/**
+ * A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is
+ * closed.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQObjectClosedException extends ActiveMQException
+{
+   private static final long serialVersionUID = 809024052184914812L;
+
+   public ActiveMQObjectClosedException()
+   {
+      super(OBJECT_CLOSED);
+   }
+
+   public ActiveMQObjectClosedException(String msg)
+   {
+      super(OBJECT_CLOSED, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQPropertyConversionException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQPropertyConversionException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQPropertyConversionException.java
new file mode 100644
index 0000000..02a0199
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQPropertyConversionException.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq.api.core;
+
+/**
+ * A PropertyConversionException is thrown by {@code org.apache.activemq.api.core.Message} methods when a
+ * property can not be converted to the expected type.
+ * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
+ * @see org.apache.activemq.api.core.Message
+ */
+public final class ActiveMQPropertyConversionException extends RuntimeException
+{
+
+   private static final long serialVersionUID = -3010008708334904332L;
+
+   public ActiveMQPropertyConversionException(final String message)
+   {
+      super(message);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQQueueExistsException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQQueueExistsException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQQueueExistsException.java
new file mode 100644
index 0000000..86257c3
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQQueueExistsException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.QUEUE_EXISTS;
+
+/**
+ * An operation failed because a queue exists on the server.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQQueueExistsException extends ActiveMQException
+{
+   private static final long serialVersionUID = -405552292451883063L;
+
+   public ActiveMQQueueExistsException()
+   {
+      super(QUEUE_EXISTS);
+   }
+
+   public ActiveMQQueueExistsException(String msg)
+   {
+      super(QUEUE_EXISTS, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSecurityException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSecurityException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSecurityException.java
new file mode 100644
index 0000000..4e4a65e
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSecurityException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.SECURITY_EXCEPTION;
+
+/**
+ * A security problem occurred (authentication issues, permission issues,...)
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQSecurityException extends ActiveMQException
+{
+   private static final long serialVersionUID = 3291210307590756881L;
+
+   public ActiveMQSecurityException()
+   {
+      super(SECURITY_EXCEPTION);
+   }
+
+   public ActiveMQSecurityException(String msg)
+   {
+      super(SECURITY_EXCEPTION, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSessionCreationException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSessionCreationException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSessionCreationException.java
new file mode 100644
index 0000000..8a7a85a
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQSessionCreationException.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.SESSION_CREATION_REJECTED;
+
+/**
+ * The creation of a session was rejected by the server (e.g. if the server is starting and has not
+ * finish to be initialized.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQSessionCreationException extends ActiveMQException
+{
+   private static final long serialVersionUID = -4486139158452585895L;
+
+   public ActiveMQSessionCreationException()
+   {
+      super(SESSION_CREATION_REJECTED);
+   }
+
+   public ActiveMQSessionCreationException(String msg)
+   {
+      super(SESSION_CREATION_REJECTED, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionOutcomeUnknownException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionOutcomeUnknownException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionOutcomeUnknownException.java
new file mode 100644
index 0000000..beced68
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionOutcomeUnknownException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.TRANSACTION_OUTCOME_UNKNOWN;
+
+/**
+ * The outcome of a transaction is unknown.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQTransactionOutcomeUnknownException extends ActiveMQException
+{
+   private static final long serialVersionUID = 7940794286427650558L;
+
+   public ActiveMQTransactionOutcomeUnknownException()
+   {
+      super(TRANSACTION_OUTCOME_UNKNOWN);
+   }
+
+   public ActiveMQTransactionOutcomeUnknownException(String msg)
+   {
+      super(TRANSACTION_OUTCOME_UNKNOWN, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionRolledBackException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionRolledBackException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionRolledBackException.java
new file mode 100644
index 0000000..8a0c180
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQTransactionRolledBackException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.TRANSACTION_ROLLED_BACK;
+
+/**
+ * A transaction was rolled back.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
+ */
+public final class ActiveMQTransactionRolledBackException extends ActiveMQException
+{
+   private static final long serialVersionUID = 5823412198677126300L;
+
+   public ActiveMQTransactionRolledBackException()
+   {
+      super(TRANSACTION_ROLLED_BACK);
+   }
+
+   public ActiveMQTransactionRolledBackException(String msg)
+   {
+      super(TRANSACTION_ROLLED_BACK, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnBlockedException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnBlockedException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnBlockedException.java
new file mode 100644
index 0000000..56639f1
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnBlockedException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.UNBLOCKED;
+
+/**
+ * A blocking call from a client was unblocked during failover.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQUnBlockedException extends ActiveMQException
+{
+   private static final long serialVersionUID = -4507889261891160608L;
+
+   public ActiveMQUnBlockedException()
+   {
+      super(UNBLOCKED);
+   }
+
+   public ActiveMQUnBlockedException(String msg)
+   {
+      super(UNBLOCKED, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnsupportedPacketException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnsupportedPacketException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnsupportedPacketException.java
new file mode 100644
index 0000000..0403bbe
--- /dev/null
+++ b/activemq-commons/src/main/java/org/apache/activemq/api/core/ActiveMQUnsupportedPacketException.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq.api.core;
+
+import static org.apache.activemq.api.core.ActiveMQExceptionType.UNSUPPORTED_PACKET;
+
+/**
+ * A packet of unsupported type was received by HornetQ PacketHandler.
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
+ */
+public final class ActiveMQUnsupportedPacketException extends ActiveMQException
+{
+   private static final long serialVersionUID = -7074681529482463675L;
+
+   public ActiveMQUnsupportedPacketException()
+   {
+      super(UNSUPPORTED_PACKET);
+   }
+
+   public ActiveMQUnsupportedPacketException(String msg)
+   {
+      super(UNSUPPORTED_PACKET, msg);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressExistsException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressExistsException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressExistsException.java
deleted file mode 100644
index bbf3da7..0000000
--- a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressExistsException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *    http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied.  See the License for the specific language governing
- * permissions and limitations under the License.
- */
-
-package org.apache.activemq.api.core;
-
-import static org.apache.activemq.api.core.HornetQExceptionType.ADDRESS_EXISTS;
-
-/**
- * An operation failed because an address exists on the server.
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
- */
-public final class HornetQAddressExistsException extends HornetQException
-{
-   private static final long serialVersionUID = 3032730450033992367L;
-
-   public HornetQAddressExistsException()
-   {
-      super(ADDRESS_EXISTS);
-   }
-
-   public HornetQAddressExistsException(String msg)
-   {
-      super(ADDRESS_EXISTS, msg);
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressFullException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressFullException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressFullException.java
deleted file mode 100644
index 7045541..0000000
--- a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAddressFullException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *    http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied.  See the License for the specific language governing
- * permissions and limitations under the License.
- */
-
-package org.apache.activemq.api.core;
-
-import static org.apache.activemq.api.core.HornetQExceptionType.ADDRESS_FULL;
-
-/**
- * An address is full.
- * @author Justin Bertram
- */
-public final class HornetQAddressFullException extends HornetQException
-{
-   private static final long serialVersionUID = 0;
-
-   public HornetQAddressFullException(String message)
-   {
-      super(ADDRESS_FULL, message);
-   }
-
-   public HornetQAddressFullException()
-   {
-      super(ADDRESS_FULL);
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/1bf2e41f/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAlreadyReplicatingException.java
----------------------------------------------------------------------
diff --git a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAlreadyReplicatingException.java b/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAlreadyReplicatingException.java
deleted file mode 100644
index 2d0731f..0000000
--- a/activemq-commons/src/main/java/org/apache/activemq/api/core/HornetQAlreadyReplicatingException.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *    http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied.  See the License for the specific language governing
- * permissions and limitations under the License.
- */
-
-package org.apache.activemq.api.core;
-
-import static org.apache.activemq.api.core.HornetQExceptionType.ALREADY_REPLICATING;
-
-/**
- * The server is already paired with a replicating backup.
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
- */
-public final class HornetQAlreadyReplicatingException extends HornetQException
-{
-   private static final long serialVersionUID = -7352538521961996152L;
-
-   public HornetQAlreadyReplicatingException()
-   {
-      super(ALREADY_REPLICATING);
-   }
-
-   public HornetQAlreadyReplicatingException(String msg)
-   {
-      super(ALREADY_REPLICATING, msg);
-   }
-}


Mime
View raw message