1 files changed, 11 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java b/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java
index 2b6a67c4f6..2ca8e57e18 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java
@@ -47,9 +47,9 @@ public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAM
     // Constructor
     public ConnectionTuneBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
     {
-        _channelMax = readUnsignedShort( buffer );
-        _frameMax = readUnsignedInteger( buffer );
-        _heartbeat = readUnsignedShort( buffer );
+        _channelMax = buffer.readUnsignedShort();
+        _frameMax = EncodingUtils.readUnsignedInteger(buffer);
+        _heartbeat = buffer.readUnsignedShort();
     }
 
     public ConnectionTuneBody(
@@ -119,4 +119,12 @@ public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAM
         return buf.toString();
     }
 
+    public static <T> T process(final MarkableDataInput buffer, final MethodProcessor<T> dispatcher) throws IOException
+    {
+
+        int channelMax = buffer.readUnsignedShort();
+        long frameMax = EncodingUtils.readUnsignedInteger(buffer);
+        int heartbeat = buffer.readUnsignedShort();
+        return dispatcher.connectionTune(channelMax, frameMax, heartbeat);
+    }
 }