activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r468441 [5/6] - in /incubator/activemq/sandbox/qpid: ./ specs/ src/main/java/org/apache/activemq/amqp/broker/ src/main/java/org/apache/activemq/amqp/command/ src/main/java/org/apache/activemq/amqp/transport/ src/main/java/org/apache/activem...
Date Fri, 27 Oct 2006 16:19:06 GMT
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileRejectBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileRejectBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class FileRejectBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 100; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new FileRejectBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        FileRejectBody object = (FileRejectBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*requeue*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        FileRejectBody object = (FileRejectBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        FileRejectBody object = (FileRejectBody)o;
+        object.deliveryTag = buffer.readLong();
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.requeue = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileReturnBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileReturnBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class FileReturnBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 70; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new FileReturnBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        FileReturnBody object = (FileReturnBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        FileReturnBody object = (FileReturnBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        FileReturnBody object = (FileReturnBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileStageBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileStageBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileStageBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/FileStageBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class FileStageBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 50; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new FileStageBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        FileStageBody object = (FileStageBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        FileStageBody object = (FileStageBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        FileStageBody object = (FileStageBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MainRegistry.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MainRegistry.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MainRegistry.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MainRegistry.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,123 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.util.Map;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class MainRegistry
+{
+    public static void register(Map map)
+    {
+        map.put(new Integer(10 * 1000 + 10), new ConnectionStartBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 11), new ConnectionStartOkBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 20), new ConnectionSecureBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 21), new ConnectionSecureOkBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 30), new ConnectionTuneBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 31), new ConnectionTuneOkBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 40), new ConnectionOpenBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 41), new ConnectionOpenOkBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 50), new ConnectionRedirectBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 60), new ConnectionCloseBodyMarshaller());         
+        map.put(new Integer(10 * 1000 + 61), new ConnectionCloseOkBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 10), new ChannelOpenBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 11), new ChannelOpenOkBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 20), new ChannelFlowBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 21), new ChannelFlowOkBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 30), new ChannelAlertBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 40), new ChannelCloseBodyMarshaller());         
+        map.put(new Integer(20 * 1000 + 41), new ChannelCloseOkBodyMarshaller());         
+        map.put(new Integer(30 * 1000 + 10), new AccessRequestBodyMarshaller());         
+        map.put(new Integer(30 * 1000 + 11), new AccessRequestOkBodyMarshaller());         
+        map.put(new Integer(40 * 1000 + 10), new ExchangeDeclareBodyMarshaller());         
+        map.put(new Integer(40 * 1000 + 11), new ExchangeDeclareOkBodyMarshaller());         
+        map.put(new Integer(40 * 1000 + 20), new ExchangeDeleteBodyMarshaller());         
+        map.put(new Integer(40 * 1000 + 21), new ExchangeDeleteOkBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 10), new QueueDeclareBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 11), new QueueDeclareOkBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 20), new QueueBindBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 21), new QueueBindOkBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 30), new QueuePurgeBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 31), new QueuePurgeOkBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 40), new QueueDeleteBodyMarshaller());         
+        map.put(new Integer(50 * 1000 + 41), new QueueDeleteOkBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 10), new BasicQosBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 11), new BasicQosOkBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 20), new BasicConsumeBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 21), new BasicConsumeOkBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 30), new BasicCancelBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 31), new BasicCancelOkBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 40), new BasicPublishBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 50), new BasicReturnBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 60), new BasicDeliverBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 70), new BasicGetBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 71), new BasicGetOkBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 72), new BasicGetEmptyBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 80), new BasicAckBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 90), new BasicRejectBodyMarshaller());         
+        map.put(new Integer(60 * 1000 + 100), new BasicRecoverBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 10), new FileQosBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 11), new FileQosOkBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 20), new FileConsumeBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 21), new FileConsumeOkBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 30), new FileCancelBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 31), new FileCancelOkBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 40), new FileOpenBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 41), new FileOpenOkBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 50), new FileStageBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 60), new FilePublishBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 70), new FileReturnBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 80), new FileDeliverBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 90), new FileAckBodyMarshaller());         
+        map.put(new Integer(70 * 1000 + 100), new FileRejectBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 10), new StreamQosBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 11), new StreamQosOkBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 20), new StreamConsumeBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 21), new StreamConsumeOkBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 30), new StreamCancelBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 31), new StreamCancelOkBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 40), new StreamPublishBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 50), new StreamReturnBodyMarshaller());         
+        map.put(new Integer(80 * 1000 + 60), new StreamDeliverBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 10), new TxSelectBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 11), new TxSelectOkBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 20), new TxCommitBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 21), new TxCommitOkBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 30), new TxRollbackBodyMarshaller());         
+        map.put(new Integer(90 * 1000 + 31), new TxRollbackOkBodyMarshaller());         
+        map.put(new Integer(100 * 1000 + 10), new DtxSelectBodyMarshaller());         
+        map.put(new Integer(100 * 1000 + 11), new DtxSelectOkBodyMarshaller());         
+        map.put(new Integer(100 * 1000 + 20), new DtxStartBodyMarshaller());         
+        map.put(new Integer(100 * 1000 + 21), new DtxStartOkBodyMarshaller());         
+        map.put(new Integer(110 * 1000 + 10), new TunnelRequestBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 10), new TestIntegerBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 11), new TestIntegerOkBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 20), new TestStringBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 21), new TestStringOkBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 30), new TestTableBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 31), new TestTableOkBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 40), new TestContentBodyMarshaller());         
+        map.put(new Integer(120 * 1000 + 41), new TestContentOkBodyMarshaller());         
+        
+    }
+}
+    
\ No newline at end of file

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MethodBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MethodBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MethodBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/MethodBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,53 @@
+/*
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.MethodBody;
+
+public abstract class MethodBodyMarshaller
+{
+
+    public int getSize(MethodBody o)
+    {
+        return 2 + 2 + getBodySize(o);
+    }
+
+    protected void writePayload(DataOutput buffer, MethodBody object)  throws IOException
+    {
+        EncodingUtils.writeUnsignedShort(buffer, getClazz());
+        EncodingUtils.writeUnsignedShort(buffer, getMethod());
+        writeMethodPayload(buffer, object);
+    }
+
+    public void populateFromBuffer(DataInput buffer, long size, MethodBody object) throws IOException
+    {
+        populateMethodBodyFromBuffer(buffer, object);
+    }
+    
+    protected abstract int getBodySize(MethodBody o);
+    protected abstract int getClazz();
+    protected abstract int getMethod();
+    public abstract void writeMethodPayload(DataOutput buffer, MethodBody object) throws IOException;
+    protected abstract void populateMethodBodyFromBuffer(DataInput buffer, MethodBody object) throws IOException;
+
+	public abstract MethodBody createBody();
+}

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,88 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueBindBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueBindBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueBindBody object = (QueueBindBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            1 /*nowait*/+
+            EncodingUtils.encodedFieldTableLength(object.arguments)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueBindBody object = (QueueBindBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+            EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueBindBody object = (QueueBindBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+        object.arguments = EncodingUtils.readFieldTable(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueBindOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueBindOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueBindOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueBindOkBody object = (QueueBindOkBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueBindOkBody object = (QueueBindOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueBindOkBody object = (QueueBindOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,90 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueDeclareBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueDeclareBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueDeclareBody object = (QueueDeclareBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            1 /*passive*/+
+            0 /*durable*/+
+            0 /*exclusive*/+
+            0 /*autoDelete*/+
+            0 /*nowait*/+
+            EncodingUtils.encodedFieldTableLength(object.arguments)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueDeclareBody object = (QueueDeclareBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.passive, object.durable, object.exclusive, object.autoDelete, object.nowait});
+            EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueDeclareBody object = (QueueDeclareBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.passive = bools[0];
+        object.durable = bools[1];
+        object.exclusive = bools[2];
+        object.autoDelete = bools[3];
+        object.nowait = bools[4];
+        object.arguments = EncodingUtils.readFieldTable(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeclareOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueDeclareOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueDeclareOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.queue)+
+            4 /*messageCount*/+
+            4 /*consumerCount*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+            EncodingUtils.writeUnsignedInteger(buffer, object.consumerCount);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+        object.queue = EncodingUtils.readShortString(buffer);
+        object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+        object.consumerCount = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,83 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueDeleteBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueDeleteBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            1 /*ifUnused*/+
+            0 /*ifEmpty*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.ifUnused, object.ifEmpty, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.ifUnused = bools[0];
+        object.ifEmpty = bools[1];
+        object.nowait = bools[2];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueueDeleteOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueueDeleteOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 41; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueueDeleteOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueueDeleteOkBody object = (QueueDeleteOkBody)o;
+        
+        return
+        4 /*messageCount*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueueDeleteOkBody object = (QueueDeleteOkBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueueDeleteOkBody object = (QueueDeleteOkBody)o;
+        object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueuePurgeBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueuePurgeBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueuePurgeBody object = (QueuePurgeBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            1 /*nowait*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueuePurgeBody object = (QueuePurgeBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueuePurgeBody object = (QueuePurgeBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/QueuePurgeOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class QueuePurgeOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new QueuePurgeOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        QueuePurgeOkBody object = (QueuePurgeOkBody)o;
+        
+        return
+        4 /*messageCount*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        QueuePurgeOkBody object = (QueuePurgeOkBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        QueuePurgeOkBody object = (QueuePurgeOkBody)o;
+        object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamCancelBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamCancelBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamCancelBody object = (StreamCancelBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*nowait*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamCancelBody object = (StreamCancelBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamCancelBody object = (StreamCancelBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamCancelOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamCancelOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamCancelOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamCancelOkBody object = (StreamCancelOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamCancelOkBody object = (StreamCancelOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamCancelOkBody object = (StreamCancelOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,86 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamConsumeBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamConsumeBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*noLocal*/+
+            0 /*exclusive*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noLocal, object.exclusive, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.noLocal = bools[0];
+        object.exclusive = bools[1];
+        object.nowait = bools[2];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamConsumeOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamConsumeOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamConsumeOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamConsumeOkBody object = (StreamConsumeOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamConsumeOkBody object = (StreamConsumeOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamConsumeOkBody object = (StreamConsumeOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamDeliverBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamDeliverBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamDeliverBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 60; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamDeliverBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamDeliverBody object = (StreamDeliverBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            8 /*deliveryTag*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.queue)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamDeliverBody object = (StreamDeliverBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamDeliverBody object = (StreamDeliverBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        object.deliveryTag = buffer.readLong();
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamPublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamPublishBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamPublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamPublishBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,84 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamPublishBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamPublishBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamPublishBody object = (StreamPublishBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            1 /*mandatory*/+
+            0 /*immediate*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamPublishBody object = (StreamPublishBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.mandatory, object.immediate});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamPublishBody object = (StreamPublishBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.mandatory = bools[0];
+        object.immediate = bools[1];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamQosBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamQosBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        
+        return
+        4 /*prefetchSize*/+
+            2 /*prefetchCount*/+
+            4 /*consumeRate*/+
+            1 /*global*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.prefetchSize);
+            EncodingUtils.writeUnsignedShort(buffer, object.prefetchCount);
+            EncodingUtils.writeUnsignedInteger(buffer, object.consumeRate);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.global});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        object.prefetchSize = EncodingUtils.readUnsignedInteger(buffer);
+        object.prefetchCount = EncodingUtils.readUnsignedShort(buffer);
+        object.consumeRate = EncodingUtils.readUnsignedInteger(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.global = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamQosOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamQosOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamQosOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamQosOkBody object = (StreamQosOkBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamQosOkBody object = (StreamQosOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamQosOkBody object = (StreamQosOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamReturnBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/StreamReturnBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class StreamReturnBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 50; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new StreamReturnBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        StreamReturnBody object = (StreamReturnBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        StreamReturnBody object = (StreamReturnBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        StreamReturnBody object = (StreamReturnBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class TestContentBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestContentBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestContentBody object = (TestContentBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestContentBody object = (TestContentBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestContentBody object = (TestContentBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestContentOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class TestContentOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 41; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestContentOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestContentOkBody object = (TestContentOkBody)o;
+        
+        return
+        4 /*contentChecksum*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestContentOkBody object = (TestContentOkBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.contentChecksum);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestContentOkBody object = (TestContentOkBody)o;
+        object.contentChecksum = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,85 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class TestIntegerBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestIntegerBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        
+        return
+        1 /*integer1*/+
+            2 /*integer2*/+
+            4 /*integer3*/+
+            8 /*integer4*/+
+            1 /*operation*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        EncodingUtils.writeUnsignedByte(buffer, object.integer1);
+            EncodingUtils.writeUnsignedShort(buffer, object.integer2);
+            EncodingUtils.writeUnsignedInteger(buffer, object.integer3);
+            buffer.writeLong(object.integer4);
+            EncodingUtils.writeUnsignedByte(buffer, object.operation);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        object.integer1 = EncodingUtils.readUnsignedByte(buffer);
+        object.integer2 = EncodingUtils.readUnsignedShort(buffer);
+        object.integer3 = EncodingUtils.readUnsignedInteger(buffer);
+        object.integer4 = buffer.readLong();
+        object.operation = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestIntegerOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class TestIntegerOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestIntegerOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestIntegerOkBody object = (TestIntegerOkBody)o;
+        
+        return
+        8 /*result*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestIntegerOkBody object = (TestIntegerOkBody)o;
+        buffer.writeLong(object.result);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestIntegerOkBody object = (TestIntegerOkBody)o;
+        object.result = buffer.readLong();
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class TestStringBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestStringBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestStringBody object = (TestStringBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.string1)+
+            4 + (object.string2 == null ? 0 : object.string2.length)+
+            1 /*operation*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestStringBody object = (TestStringBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.string1);
+            EncodingUtils.writeLongstr(buffer, object.string2);
+            EncodingUtils.writeUnsignedByte(buffer, object.operation);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestStringBody object = (TestStringBody)o;
+        object.string1 = EncodingUtils.readShortString(buffer);
+        object.string2 = EncodingUtils.readLongstr(buffer);
+        object.operation = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 



Mime
View raw message