1 files changed, 80 insertions, 7 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/ConnectionRedirectBody.java b/java/common/src/main/java/org/apache/qpid/framing/ConnectionRedirectBody.java
index df200e8572..569e9d1cc1 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ConnectionRedirectBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ConnectionRedirectBody.java
@@ -22,17 +22,90 @@
 /*
  * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
  * Supported AMQP version:
-  *   0-9
-  *   0-91
-  *   8-0
-  */
+ *   8-0
+ */
 
 package org.apache.qpid.framing;
 
-public interface ConnectionRedirectBody extends EncodableAMQDataBlock, AMQMethodBody
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.AMQException;
+import org.apache.qpid.codec.MarkableDataInput;
+
+public class ConnectionRedirectBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
 {
+    private final int _ownMethodId;
+
+    public static final int CLASS_ID =  10;
+
+    // Fields declared in specification
+    private final AMQShortString _host; // [host]
+    private final AMQShortString _knownHosts; // [knownHosts]
+
+    // Constructor
+    public ConnectionRedirectBody(MarkableDataInput buffer, ProtocolVersion protocolVersion) throws AMQFrameDecodingException, IOException
+    {
+        _ownMethodId = ProtocolVersion.v8_0.equals(protocolVersion) ? 50 : 42;
+        _host = readAMQShortString( buffer );
+        _knownHosts = readAMQShortString( buffer );
+    }
+
+    public ConnectionRedirectBody(ProtocolVersion protocolVersion, AMQShortString host, AMQShortString knownHosts)
+    {
+        _ownMethodId = ProtocolVersion.v8_0.equals(protocolVersion) ? 50 : 42;
+        _host = host;
+        _knownHosts = knownHosts;
+    }
+
+    public int getClazz()
+    {
+        return CLASS_ID;
+    }
+
+    public int getMethod()
+    {
+        return _ownMethodId;
+    }
+
+    public final AMQShortString getHost()
+    {
+        return _host;
+    }
+    public final AMQShortString getKnownHosts()
+    {
+        return _knownHosts;
+    }
+
+    protected int getBodySize()
+    {
+        int size = 0;
+        size += getSizeOf( _host );
+        size += getSizeOf( _knownHosts );
+        return size;
+    }
+
+    public void writeMethodPayload(DataOutput buffer) throws IOException
+    {
+        writeAMQShortString( buffer, _host );
+        writeAMQShortString( buffer, _knownHosts );
+    }
+
+    public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+	{
+        return dispatcher.dispatchConnectionRedirect(this, channelId);
+	}
 
-    public AMQShortString getHost();
+    public String toString()
+    {
+        StringBuilder buf = new StringBuilder("[ConnectionRedirectBodyImpl: ");
+        buf.append( "host=" );
+        buf.append(  getHost() );
+        buf.append( ", " );
+        buf.append( "knownHosts=" );
+        buf.append(  getKnownHosts() );
+        buf.append("]");
+        return buf.toString();
+    }
 
-    public AMQShortString getKnownHosts();
 }