1 files changed, 3 insertions, 1 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);
     }
 }