activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r462621 [4/7] - in /incubator/activemq/sandbox/qpid: ./ src/main/java/ src/main/java/org/ src/main/java/org/apache/ src/main/java/org/apache/activemq/ src/main/java/org/apache/activemq/qpid/ src/main/java/org/apache/activemq/qpid/command/ s...
Date Tue, 10 Oct 2006 22:43:51 GMT
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicConsumeBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicConsumeBody object = (BasicConsumeBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*noLocal*/+
+            0 /*noAck*/+
+            0 /*exclusive*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicConsumeBody object = (BasicConsumeBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noLocal, object.noAck, object.exclusive, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicConsumeBody object = (BasicConsumeBody)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.noAck = bools[1];
+        object.exclusive = bools[2];
+        object.nowait = bools[3];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicConsumeOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicDeliverBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 60; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicDeliverBody object = (BasicDeliverBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            8 /*deliveryTag*/+
+            1 /*redelivered*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicDeliverBody object = (BasicDeliverBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.redelivered});
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicDeliverBody object = (BasicDeliverBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        object.deliveryTag = buffer.readLong();
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.redelivered = bools[0];
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 70; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicGetBody object = (BasicGetBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            1 /*noAck*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetBody object = (BasicGetBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noAck});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetBody object = (BasicGetBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.noAck = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetEmptyBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 72; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.clusterId)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.clusterId);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+        object.clusterId = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 71; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicGetOkBody object = (BasicGetOkBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*redelivered*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            4 /*messageCount*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetOkBody object = (BasicGetOkBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.redelivered});
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicGetOkBody object = (BasicGetOkBody)o;
+        object.deliveryTag = buffer.readLong();
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.redelivered = bools[0];
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,81 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicPublishBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicPublishBody object = (BasicPublishBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            1 /*mandatory*/+
+            0 /*immediate*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicPublishBody object = (BasicPublishBody)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, AMQMethodBody o) throws IOException
+    {
+        BasicPublishBody object = (BasicPublishBody)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/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicQosBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicQosBody object = (BasicQosBody)o;
+        
+        return
+        4 /*prefetchSize*/+
+            2 /*prefetchCount*/+
+            1 /*global*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicQosBody object = (BasicQosBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.prefetchSize);
+            EncodingUtils.writeUnsignedShort(buffer, object.prefetchCount);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.global});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicQosBody object = (BasicQosBody)o;
+        object.prefetchSize = EncodingUtils.readUnsignedInteger(buffer);
+        object.prefetchCount = EncodingUtils.readUnsignedShort(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.global = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicQosOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicQosOkBody object = (BasicQosOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicQosOkBody object = (BasicQosOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicQosOkBody object = (BasicQosOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicRecoverBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 100; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicRecoverBody object = (BasicRecoverBody)o;
+        
+        return
+        1 /*requeue*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicRecoverBody object = (BasicRecoverBody)o;
+        EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicRecoverBody object = (BasicRecoverBody)o;
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.requeue = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicRejectBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 90; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicRejectBody object = (BasicRejectBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*requeue*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicRejectBody object = (BasicRejectBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicRejectBody object = (BasicRejectBody)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/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicReturnBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 50; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        BasicReturnBody object = (BasicReturnBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        BasicReturnBody object = (BasicReturnBody)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, AMQMethodBody o) throws IOException
+    {
+        BasicReturnBody object = (BasicReturnBody)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/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelAlertBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelAlertBody object = (ChannelAlertBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            EncodingUtils.encodedFieldTableLength(object.details)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelAlertBody object = (ChannelAlertBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeFieldTableBytes(buffer, object.details);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelAlertBody object = (ChannelAlertBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.details = EncodingUtils.readFieldTable(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelCloseBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelCloseBody object = (ChannelCloseBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            2 /*classId*/+
+            2 /*methodId*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelCloseBody object = (ChannelCloseBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeUnsignedShort(buffer, object.classId);
+            EncodingUtils.writeUnsignedShort(buffer, object.methodId);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelCloseBody object = (ChannelCloseBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.classId = EncodingUtils.readUnsignedShort(buffer);
+        object.methodId = EncodingUtils.readUnsignedShort(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelCloseOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 41; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelFlowBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelFlowBody object = (ChannelFlowBody)o;
+        
+        return
+        1 /*active*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelFlowBody object = (ChannelFlowBody)o;
+        EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelFlowBody object = (ChannelFlowBody)o;
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.active = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelFlowOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+        
+        return
+        1 /*active*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+        EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.active = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelOpenBody object = (ChannelOpenBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.outOfBand)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelOpenBody object = (ChannelOpenBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.outOfBand);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelOpenBody object = (ChannelOpenBody)o;
+        object.outOfBand = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 20; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionCloseBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 60; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionCloseBody object = (ConnectionCloseBody)o;
+        
+        return
+        2 /*replyCode*/+
+            EncodingUtils.encodedShortStringLength(object.replyText)+
+            2 /*classId*/+
+            2 /*methodId*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionCloseBody object = (ConnectionCloseBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeUnsignedShort(buffer, object.classId);
+            EncodingUtils.writeUnsignedShort(buffer, object.methodId);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionCloseBody object = (ConnectionCloseBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.classId = EncodingUtils.readUnsignedShort(buffer);
+        object.methodId = EncodingUtils.readUnsignedShort(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionCloseOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 61; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionOpenBody object = (ConnectionOpenBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.virtualHost)+
+            EncodingUtils.encodedShortStringLength(object.capabilities)+
+            1 /*insist*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionOpenBody object = (ConnectionOpenBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.virtualHost);
+            EncodingUtils.writeShortStringBytes(buffer, object.capabilities);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.insist});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionOpenBody object = (ConnectionOpenBody)o;
+        object.virtualHost = EncodingUtils.readShortString(buffer);
+        object.capabilities = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.insist = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 41; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.knownHosts)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+        object.knownHosts = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionRedirectBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 50; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.host)+
+            EncodingUtils.encodedShortStringLength(object.knownHosts)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.host);
+            EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+        object.host = EncodingUtils.readShortString(buffer);
+        object.knownHosts = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionSecureBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionSecureBody object = (ConnectionSecureBody)o;
+        
+        return
+        4 + (object.challenge == null ? 0 : object.challenge.length)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionSecureBody object = (ConnectionSecureBody)o;
+        EncodingUtils.writeLongstr(buffer, object.challenge);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionSecureBody object = (ConnectionSecureBody)o;
+        object.challenge = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionSecureOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+        
+        return
+        4 + (object.response == null ? 0 : object.response.length)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+        EncodingUtils.writeLongstr(buffer, object.response);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+        object.response = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionStartBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionStartBody object = (ConnectionStartBody)o;
+        
+        return
+        1 /*versionMajor*/+
+            1 /*versionMinor*/+
+            EncodingUtils.encodedFieldTableLength(object.serverProperties)+
+            4 + (object.mechanisms == null ? 0 : object.mechanisms.length)+
+            4 + (object.locales == null ? 0 : object.locales.length)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionStartBody object = (ConnectionStartBody)o;
+        EncodingUtils.writeUnsignedByte(buffer, object.versionMajor);
+            EncodingUtils.writeUnsignedByte(buffer, object.versionMinor);
+            EncodingUtils.writeFieldTableBytes(buffer, object.serverProperties);
+            EncodingUtils.writeLongstr(buffer, object.mechanisms);
+            EncodingUtils.writeLongstr(buffer, object.locales);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionStartBody object = (ConnectionStartBody)o;
+        object.versionMajor = EncodingUtils.readUnsignedByte(buffer);
+        object.versionMinor = EncodingUtils.readUnsignedByte(buffer);
+        object.serverProperties = EncodingUtils.readFieldTable(buffer);
+        object.mechanisms = EncodingUtils.readLongstr(buffer);
+        object.locales = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionStartOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+        
+        return
+        EncodingUtils.encodedFieldTableLength(object.clientProperties)+
+            EncodingUtils.encodedShortStringLength(object.mechanism)+
+            4 + (object.response == null ? 0 : object.response.length)+
+            EncodingUtils.encodedShortStringLength(object.locale)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+        EncodingUtils.writeFieldTableBytes(buffer, object.clientProperties);
+            EncodingUtils.writeShortStringBytes(buffer, object.mechanism);
+            EncodingUtils.writeLongstr(buffer, object.response);
+            EncodingUtils.writeShortStringBytes(buffer, object.locale);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+        object.clientProperties = EncodingUtils.readFieldTable(buffer);
+        object.mechanism = EncodingUtils.readShortString(buffer);
+        object.response = EncodingUtils.readLongstr(buffer);
+        object.locale = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionTuneBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionTuneBody object = (ConnectionTuneBody)o;
+        
+        return
+        2 /*channelMax*/+
+            4 /*frameMax*/+
+            2 /*heartbeat*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionTuneBody object = (ConnectionTuneBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.channelMax);
+            EncodingUtils.writeUnsignedInteger(buffer, object.frameMax);
+            EncodingUtils.writeUnsignedShort(buffer, object.heartbeat);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionTuneBody object = (ConnectionTuneBody)o;
+        object.channelMax = EncodingUtils.readUnsignedShort(buffer);
+        object.frameMax = EncodingUtils.readUnsignedInteger(buffer);
+        object.heartbeat = EncodingUtils.readUnsignedShort(buffer);
+        		 
+    }
+} 



Mime
View raw message