1 files changed, 13 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/ProtocolVersionException.java b/java/common/src/main/java/org/apache/qpid/transport/ProtocolVersionException.java
index 2de0c169a5..db8064268c 100644
--- a/java/common/src/main/java/org/apache/qpid/transport/ProtocolVersionException.java
+++ b/java/common/src/main/java/org/apache/qpid/transport/ProtocolVersionException.java
@@ -26,19 +26,24 @@ package org.apache.qpid.transport;
  *
  */
 
-public final class ProtocolVersionException extends TransportException
+public final class ProtocolVersionException extends ConnectionException
 {
 
     private final byte major;
     private final byte minor;
 
-    public ProtocolVersionException(byte major, byte minor)
+    public ProtocolVersionException(byte major, byte minor, Throwable cause)
     {
-        super(String.format("version missmatch: %s-%s", major, minor));
+        super(String.format("version mismatch: %s-%s", major, minor), cause);
         this.major = major;
         this.minor = minor;
     }
 
+    public ProtocolVersionException(byte major, byte minor)
+    {
+        this(major, minor, null);
+    }
+
     public byte getMajor()
     {
         return this.major;
@@ -49,4 +54,9 @@ public final class ProtocolVersionException extends TransportException
         return this.minor;
     }
 
+    @Override public void rethrow()
+    {
+        throw new ProtocolVersionException(major, minor, this);
+    }
+
 }