1 files changed, 169 insertions, 13 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/BasicConsumeBody.java b/java/common/src/main/java/org/apache/qpid/framing/BasicConsumeBody.java
index d263899082..c198d3938b 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/BasicConsumeBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/BasicConsumeBody.java
@@ -22,29 +22,185 @@
 /*
  * 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 BasicConsumeBody extends EncodableAMQDataBlock, AMQMethodBody
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.AMQException;
+import org.apache.qpid.codec.MarkableDataInput;
+
+public class BasicConsumeBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
 {
+    private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+    {
+        public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+        {
+            return new BasicConsumeBody(in);
+        }
+    };
+
+    public static AMQMethodBodyInstanceFactory getFactory()
+    {
+        return FACTORY_INSTANCE;
+    }
+
+    public static final int CLASS_ID =  60;
+    public static final int METHOD_ID = 20;
+
+    // Fields declared in specification
+    private final int _ticket; // [ticket]
+    private final AMQShortString _queue; // [queue]
+    private final AMQShortString _consumerTag; // [consumerTag]
+    private final byte _bitfield0; // [noLocal, noAck, exclusive, nowait]
+    private final FieldTable _arguments; // [arguments]
+
+    // Constructor
+    public BasicConsumeBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+    {
+        _ticket = readUnsignedShort( buffer );
+        _queue = readAMQShortString( buffer );
+        _consumerTag = readAMQShortString( buffer );
+        _bitfield0 = readBitfield( buffer );
+        _arguments = readFieldTable( buffer );
+    }
+
+    public BasicConsumeBody(
+            int ticket,
+            AMQShortString queue,
+            AMQShortString consumerTag,
+            boolean noLocal,
+            boolean noAck,
+            boolean exclusive,
+            boolean nowait,
+            FieldTable arguments
+                           )
+    {
+        _ticket = ticket;
+        _queue = queue;
+        _consumerTag = consumerTag;
+        byte bitfield0 = (byte)0;
+        if( noLocal )
+        {
+            bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+        }
+
+        if( noAck )
+        {
+            bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+        }
+
+        if( exclusive )
+        {
+            bitfield0 = (byte) (((int) bitfield0) | (1 << 2));
+        }
+
+        if( nowait )
+        {
+            bitfield0 = (byte) (((int) bitfield0) | (1 << 3));
+        }
+
+        _bitfield0 = bitfield0;
+        _arguments = arguments;
+    }
 
-    public FieldTable getArguments();
+    public int getClazz()
+    {
+        return CLASS_ID;
+    }
 
-    public AMQShortString getConsumerTag();
+    public int getMethod()
+    {
+        return METHOD_ID;
+    }
 
-    public boolean getExclusive();
+    public final int getTicket()
+    {
+        return _ticket;
+    }
+    public final AMQShortString getQueue()
+    {
+        return _queue;
+    }
+    public final AMQShortString getConsumerTag()
+    {
+        return _consumerTag;
+    }
+    public final boolean getNoLocal()
+    {
+        return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+    }
+    public final boolean getNoAck()
+    {
+        return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+    }
+    public final boolean getExclusive()
+    {
+        return (((int)(_bitfield0)) & ( 1 << 2)) != 0;
+    }
+    public final boolean getNowait()
+    {
+        return (((int)(_bitfield0)) & ( 1 << 3)) != 0;
+    }
+    public final FieldTable getArguments()
+    {
+        return _arguments;
+    }
 
-    public boolean getNoAck();
+    protected int getBodySize()
+    {
+        int size = 3;
+        size += getSizeOf( _queue );
+        size += getSizeOf( _consumerTag );
+        size += getSizeOf( _arguments );
+        return size;
+    }
 
-    public boolean getNoLocal();
+    public void writeMethodPayload(DataOutput buffer) throws IOException
+    {
+        writeUnsignedShort( buffer, _ticket );
+        writeAMQShortString( buffer, _queue );
+        writeAMQShortString( buffer, _consumerTag );
+        writeBitfield( buffer, _bitfield0 );
+        writeFieldTable( buffer, _arguments );
+    }
 
-    public boolean getNowait();
+    public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+	{
+        return dispatcher.dispatchBasicConsume(this, channelId);
+	}
 
-    public AMQShortString getQueue();
+    public String toString()
+    {
+        StringBuilder buf = new StringBuilder("[BasicConsumeBodyImpl: ");
+        buf.append( "ticket=" );
+        buf.append(  getTicket() );
+        buf.append( ", " );
+        buf.append( "queue=" );
+        buf.append(  getQueue() );
+        buf.append( ", " );
+        buf.append( "consumerTag=" );
+        buf.append(  getConsumerTag() );
+        buf.append( ", " );
+        buf.append( "noLocal=" );
+        buf.append(  getNoLocal() );
+        buf.append( ", " );
+        buf.append( "noAck=" );
+        buf.append(  getNoAck() );
+        buf.append( ", " );
+        buf.append( "exclusive=" );
+        buf.append(  getExclusive() );
+        buf.append( ", " );
+        buf.append( "nowait=" );
+        buf.append(  getNowait() );
+        buf.append( ", " );
+        buf.append( "arguments=" );
+        buf.append(  getArguments() );
+        buf.append("]");
+        return buf.toString();
+    }
 
-    public int getTicket();
 }