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.tay...@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.tay...@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.tay...@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.tay...@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....@jboss.com";>Tim Fox</a> + * @author <a href="mailto:andy.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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:jmes...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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.tay...@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); - } -}
