activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r462621 [5/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/ConnectionTuneOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.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 ConnectionTuneOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 10; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ConnectionTuneOkBody object = (ConnectionTuneOkBody)o;
+        
+        return
+        2 /*channelMax*/+
+            4 /*frameMax*/+
+            2 /*heartbeat*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ConnectionTuneOkBody object = (ConnectionTuneOkBody)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
+    {
+        ConnectionTuneOkBody object = (ConnectionTuneOkBody)o;
+        object.channelMax = EncodingUtils.readUnsignedShort(buffer);
+        object.frameMax = EncodingUtils.readUnsignedInteger(buffer);
+        object.heartbeat = EncodingUtils.readUnsignedShort(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.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 DtxSelectBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 100; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        DtxSelectBody object = (DtxSelectBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxSelectBody object = (DtxSelectBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxSelectBody object = (DtxSelectBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.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 DtxSelectOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 100; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        DtxSelectOkBody object = (DtxSelectOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxSelectOkBody object = (DtxSelectOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxSelectOkBody object = (DtxSelectOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.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 DtxStartBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 100; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        DtxStartBody object = (DtxStartBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.dtxIdentifier)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxStartBody object = (DtxStartBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.dtxIdentifier);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxStartBody object = (DtxStartBody)o;
+        object.dtxIdentifier = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.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 DtxStartOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 100; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        DtxStartOkBody object = (DtxStartOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxStartOkBody object = (DtxStartOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        DtxStartOkBody object = (DtxStartOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java Tue Oct 10 15:43:45 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.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 ExchangeDeclareBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 40; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.type)+
+            1 /*passive*/+
+            0 /*durable*/+
+            0 /*autoDelete*/+
+            0 /*internal*/+
+            0 /*nowait*/+
+            EncodingUtils.encodedFieldTableLength(object.arguments)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.type);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.passive, object.durable, object.autoDelete, object.internal, object.nowait});
+            EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.type = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.passive = bools[0];
+        object.durable = bools[1];
+        object.autoDelete = bools[2];
+        object.internal = bools[3];
+        object.nowait = bools[4];
+        object.arguments = EncodingUtils.readFieldTable(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.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 ExchangeDeclareOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 40; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,78 @@
+/**
+*
+* 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 ExchangeDeleteBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 40; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            1 /*ifUnused*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.ifUnused, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.ifUnused = bools[0];
+        object.nowait = bools[1];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.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 ExchangeDeleteOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 40; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.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 FileAckBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 90; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileAckBody object = (FileAckBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*multiple*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileAckBody object = (FileAckBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.multiple});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileAckBody object = (FileAckBody)o;
+        object.deliveryTag = buffer.readLong();
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.multiple = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.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 FileCancelBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileCancelBody object = (FileCancelBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*nowait*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileCancelBody object = (FileCancelBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileCancelBody object = (FileCancelBody)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/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.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 FileCancelOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileCancelOkBody object = (FileCancelOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileCancelOkBody object = (FileCancelOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileCancelOkBody object = (FileCancelOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.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 FileConsumeBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileConsumeBody object = (FileConsumeBody)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
+    {
+        FileConsumeBody object = (FileConsumeBody)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
+    {
+        FileConsumeBody object = (FileConsumeBody)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/FileConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.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 FileConsumeOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileConsumeOkBody object = (FileConsumeOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileConsumeOkBody object = (FileConsumeOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileConsumeOkBody object = (FileConsumeOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.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 FileDeliverBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 80; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileDeliverBody object = (FileDeliverBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            8 /*deliveryTag*/+
+            1 /*redelivered*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            EncodingUtils.encodedShortStringLength(object.identifier)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileDeliverBody object = (FileDeliverBody)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);
+            EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileDeliverBody object = (FileDeliverBody)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);
+        object.identifier = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.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 FileOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileOpenBody object = (FileOpenBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.identifier)+
+            8 /*contentSize*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileOpenBody object = (FileOpenBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+            buffer.writeLong(object.contentSize);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileOpenBody object = (FileOpenBody)o;
+        object.identifier = EncodingUtils.readShortString(buffer);
+        object.contentSize = buffer.readLong();
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.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 FileOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 41; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileOpenOkBody object = (FileOpenOkBody)o;
+        
+        return
+        8 /*stagedSize*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileOpenOkBody object = (FileOpenOkBody)o;
+        buffer.writeLong(object.stagedSize);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileOpenOkBody object = (FileOpenOkBody)o;
+        object.stagedSize = buffer.readLong();
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java Tue Oct 10 15:43:45 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.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 FilePublishBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 60; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FilePublishBody object = (FilePublishBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.exchange)+
+            EncodingUtils.encodedShortStringLength(object.routingKey)+
+            1 /*mandatory*/+
+            0 /*immediate*/+
+            EncodingUtils.encodedShortStringLength(object.identifier)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FilePublishBody object = (FilePublishBody)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});
+            EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FilePublishBody object = (FilePublishBody)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];
+        object.identifier = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.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 FileQosBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileQosBody object = (FileQosBody)o;
+        
+        return
+        4 /*prefetchSize*/+
+            2 /*prefetchCount*/+
+            1 /*global*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileQosBody object = (FileQosBody)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
+    {
+        FileQosBody object = (FileQosBody)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/FileQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.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 FileQosOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 70; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileQosOkBody object = (FileQosOkBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileQosOkBody object = (FileQosOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileQosOkBody object = (FileQosOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.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 FileRejectBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    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;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileRejectBody object = (FileRejectBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*requeue*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileRejectBody object = (FileRejectBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.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 FileReturnBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    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;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileReturnBody object = (FileReturnBody)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
+    {
+        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, AMQMethodBody 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/qpid/marshaller/v8_0/FileStageBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.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 FileStageBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    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;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        FileStageBody object = (FileStageBody)o;
+        return 0; 
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        FileStageBody object = (FileStageBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        FileStageBody object = (FileStageBody)o;
+        		 
+    }
+} 

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,87 @@
+/**
+*
+* 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 QueueDeclareBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    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;
+    }
+
+    protected int getBodySize(AMQMethodBody 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)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.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 QueueDeclareOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    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;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.queue)+
+            4 /*messageCount*/+
+            4 /*consumerCount*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody o) throws IOException
+    {
+        QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+        object.queue = EncodingUtils.readShortString(buffer);
+        object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+        object.consumerCount = EncodingUtils.readUnsignedInteger(buffer);
+        		 
+    }
+} 



Mime
View raw message