summaryrefslogtreecommitdiff
path: root/java/common
diff options
context:
space:
mode:
Diffstat (limited to 'java/common')
-rw-r--r--java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java4
-rw-r--r--java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java4
2 files changed, 6 insertions, 2 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java b/java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java
index 6af681f479..f1f973542d 100644
--- a/java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java
+++ b/java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java
@@ -20,10 +20,12 @@
*/
package org.apache.qpid;
+import org.apache.qpid.protocol.AMQConstant;
+
public class AMQTimeoutException extends AMQException
{
public AMQTimeoutException(String message)
{
- super(message);
+ super(AMQConstant.REQUEST_TIMEOUT, message);
}
}
diff --git a/java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java b/java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java
index 05365de137..0c4736a348 100644
--- a/java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java
+++ b/java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java
@@ -90,6 +90,8 @@ public final class AMQConstant
public static final AMQConstant IN_USE = new AMQConstant(406, "In use", true);
+ public static final AMQConstant REQUEST_TIMEOUT = new AMQConstant(408, "Request Timeout", true);
+
public static final AMQConstant FRAME_ERROR = new AMQConstant(501, "frame error", true);
public static final AMQConstant SYNTAX_ERROR = new AMQConstant(502, "syntax error", true);
@@ -100,7 +102,7 @@ public final class AMQConstant
public static final AMQConstant RESOURCE_ERROR = new AMQConstant(506, "resource error", true);
- public static final AMQConstant NOT_ALLOWED = new AMQConstant(530, "not allowed", true);
+ public static final AMQConstant NOT_ALLOWED = new AMQConstant(507, "not allowed", true);
public static final AMQConstant NOT_IMPLEMENTED = new AMQConstant(540, "not implemented", true);