activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r462621 [6/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/QueueDeleteBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,80 @@
+/**
+*
+* 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 QueueDeleteBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 50; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            1 /*ifUnused*/+
+            0 /*ifEmpty*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.ifUnused, object.ifEmpty, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        QueueDeleteBody object = (QueueDeleteBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.ifUnused = bools[0];
+        object.ifEmpty = bools[1];
+        object.nowait = bools[2];
+        		 
+    }
+} 

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

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

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

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

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,83 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*    http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+    
+package org.apache.activemq.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 StreamConsumeBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        
+        return
+        2 /*ticket*/+
+            EncodingUtils.encodedShortStringLength(object.queue)+
+            EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*noLocal*/+
+            0 /*exclusive*/+
+            0 /*nowait*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.queue);
+            EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noLocal, object.exclusive, object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamConsumeBody object = (StreamConsumeBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.queue = EncodingUtils.readShortString(buffer);
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.noLocal = bools[0];
+        object.exclusive = bools[1];
+        object.nowait = bools[2];
+        		 
+    }
+} 

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

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.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 StreamPublishBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 40; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        StreamPublishBody object = (StreamPublishBody)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
+    {
+        StreamPublishBody object = (StreamPublishBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.mandatory, object.immediate});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamPublishBody object = (StreamPublishBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.mandatory = bools[0];
+        object.immediate = bools[1];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.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 StreamQosBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        
+        return
+        4 /*prefetchSize*/+
+            2 /*prefetchCount*/+
+            4 /*consumeRate*/+
+            1 /*global*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        EncodingUtils.writeUnsignedInteger(buffer, object.prefetchSize);
+            EncodingUtils.writeUnsignedShort(buffer, object.prefetchCount);
+            EncodingUtils.writeUnsignedInteger(buffer, object.consumeRate);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.global});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamQosBody object = (StreamQosBody)o;
+        object.prefetchSize = EncodingUtils.readUnsignedInteger(buffer);
+        object.prefetchCount = EncodingUtils.readUnsignedShort(buffer);
+        object.consumeRate = EncodingUtils.readUnsignedInteger(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.global = bools[0];
+        		 
+    }
+} 

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.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 StreamReturnBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 80; 	
+    public static final int METHOD_ID = 50; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        StreamReturnBody object = (StreamReturnBody)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
+    {
+        StreamReturnBody object = (StreamReturnBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+            EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+            EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+            EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        StreamReturnBody object = (StreamReturnBody)o;
+        object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+        object.replyText = EncodingUtils.readShortString(buffer);
+        object.exchange = EncodingUtils.readShortString(buffer);
+        object.routingKey = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 

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

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.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 TestIntegerBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        
+        return
+        1 /*integer1*/+
+            2 /*integer2*/+
+            4 /*integer3*/+
+            8 /*integer4*/+
+            1 /*operation*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        EncodingUtils.writeUnsignedByte(buffer, object.integer1);
+            EncodingUtils.writeUnsignedShort(buffer, object.integer2);
+            EncodingUtils.writeUnsignedInteger(buffer, object.integer3);
+            buffer.writeLong(object.integer4);
+            EncodingUtils.writeUnsignedByte(buffer, object.operation);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        TestIntegerBody object = (TestIntegerBody)o;
+        object.integer1 = EncodingUtils.readUnsignedByte(buffer);
+        object.integer2 = EncodingUtils.readUnsignedShort(buffer);
+        object.integer3 = EncodingUtils.readUnsignedInteger(buffer);
+        object.integer4 = buffer.readLong();
+        object.operation = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.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 TestStringBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        TestStringBody object = (TestStringBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.string1)+
+            4 + (object.string2 == null ? 0 : object.string2.length)+
+            1 /*operation*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        TestStringBody object = (TestStringBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.string1);
+            EncodingUtils.writeLongstr(buffer, object.string2);
+            EncodingUtils.writeUnsignedByte(buffer, object.operation);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        TestStringBody object = (TestStringBody)o;
+        object.string1 = EncodingUtils.readShortString(buffer);
+        object.string2 = EncodingUtils.readLongstr(buffer);
+        object.operation = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 

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

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.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 TestTableBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        TestTableBody object = (TestTableBody)o;
+        
+        return
+        EncodingUtils.encodedFieldTableLength(object.table)+
+            1 /*integerOp*/+
+            1 /*stringOp*/		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        TestTableBody object = (TestTableBody)o;
+        EncodingUtils.writeFieldTableBytes(buffer, object.table);
+            EncodingUtils.writeUnsignedByte(buffer, object.integerOp);
+            EncodingUtils.writeUnsignedByte(buffer, object.stringOp);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        TestTableBody object = (TestTableBody)o;
+        object.table = EncodingUtils.readFieldTable(buffer);
+        object.integerOp = EncodingUtils.readUnsignedByte(buffer);
+        object.stringOp = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.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 TestTableOkBodyMarshaller extends AMQMethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+    protected int getBodySize(AMQMethodBody o)
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        
+        return
+        8 /*integerResult*/+
+            4 + (object.stringResult == null ? 0 : object.stringResult.length)		 
+        ;
+         
+    }
+
+    protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        buffer.writeLong(object.integerResult);
+            EncodingUtils.writeLongstr(buffer, object.stringResult);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        object.integerResult = buffer.readLong();
+        object.stringResult = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

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

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

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

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

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

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

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

Modified: incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl?view=diff&rev=462621&r1=462620&r2=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl (original)
+++ incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl Tue Oct 10 15:43:45 2006
@@ -24,20 +24,9 @@
 
 <xsl:param name="major"/>
 <xsl:param name="minor"/>
-<xsl:param name="registry_name"/>
-<xsl:param name="version_list_name"/>
 
 <xsl:template match="/"> 
     <xsl:apply-templates mode="generate-multi" select="frames"/>
-    <xsl:apply-templates mode="generate-registry" select="frames"/>
-</xsl:template>
-
-<!-- processes all frames outputting the classes in a single stream -->
-<!-- (useful for debugging etc) -->
-<xsl:template match="frame" mode="generate-single"> 
-    <xsl:call-template name="generate-class">
-        <xsl:with-param name="f" select="."/>
-    </xsl:call-template>
 </xsl:template>
 
 <!-- generates seperate file for each class/frame -->
@@ -57,66 +46,19 @@
     <xsl:value-of select="amq:copyright()"/>    
 package org.apache.activemq.qpid.command;
 
+import org.apache.activemq.qpid.*;
+
 /**
  * This class is autogenerated, do not modify. [From <xsl:value-of select="$f/parent::frames/@protocol"/>]
  */
-public class <xsl:value-of select="$f/@name"/> extends AMQMethodBody implements EncodableAMQDataBlock
+public class <xsl:value-of select="$f/@name"/> extends AMQMethodBody
 { 
-    public static final int CLASS_ID = <xsl:value-of select="$f/@class-id"/>; 	
-    public static final int METHOD_ID = <xsl:value-of select="$f/@method-id"/>; 	
-
     <xsl:for-each select="$f/field"> 
         <xsl:text>public </xsl:text><xsl:value-of select="@java-type"/>
         <xsl:text> </xsl:text>
         <xsl:value-of select="@name"/>;    
     </xsl:for-each> 
 
-    protected int getClazz()
-    {
-        return <xsl:value-of select="$f/@class-id"/>;
-    }
-   
-    protected int getMethod()
-    {
-        return <xsl:value-of select="$f/@method-id"/>;
-    }
-
-    protected int getBodySize()
-    {
-        <xsl:choose> 
-        <xsl:when test="$f/field">
-        return
-        <xsl:for-each select="$f/field">
-            <xsl:if test="position() != 1">+
-            </xsl:if>
-            <xsl:value-of select="amq:field-length(.)"/>
-        </xsl:for-each>		 
-        ;
-        </xsl:when>
-        <xsl:otherwise>return 0;</xsl:otherwise>
-        </xsl:choose> 
-    }
-
-    protected void writeMethodPayload(ByteBuffer buffer)
-    {
-        <xsl:for-each select="$f/field">
-            <xsl:if test="@type != 'bit'">
-                <xsl:value-of select="amq:encoder(.)"/>;
-            </xsl:if>
-            <xsl:if test="@type = 'bit' and @boolean-index = 1">
-                <xsl:text>EncodingUtils.writeBooleans(buffer, new boolean[]{</xsl:text>
-                <xsl:value-of select="$f/field[@type='bit']/@name" separator=", "/>});
-            </xsl:if>
-        </xsl:for-each>		 
-    }
-
-    public void populateMethodBodyFromBuffer(ByteBuffer buffer) throws AMQFrameDecodingException
-    {
-        <xsl:for-each select="$f/field">
-            <xsl:value-of select="amq:decoder(.)"/>;
-        </xsl:for-each>		 
-    }
-
     public String toString()
     {
         StringBuffer buf = new StringBuffer(super.toString());
@@ -139,100 +81,5 @@
     }
 } 
 </xsl:template> 
-
-<xsl:template match="/" mode="generate-registry">
-     <xsl:text>Matching root for registry mode!</xsl:text>
-     <xsl:value-of select="."/> 
-     <xsl:apply-templates select="frames" mode="generate-registry"/>
-</xsl:template>
-
-<xsl:template match="registries" mode="generate-registry">
-Wrote MethodBodyDecoderRegistry.java
-    <xsl:result-document href="MethodBodyDecoderRegistry.java" format="textFormat">
-    <xsl:value-of select="amq:copyright()"/>    
-<!-- package org.apache.qpid.framing_<xsl:value-of select="$major"/>_<xsl:value-of select="$minor"/>; -->
-package org.apache.qpid.framing;
-
-import java.util.Map;
-import java.util.HashMap;
-import org.apache.log4j.Logger;
-import org.apache.qpid.AMQException;
-import org.apache.qpid.framing.AMQFrameDecodingException;
-import org.apache.qpid.framing.AMQMethodBody;
-
-/**
- * This class is autogenerated, do not modify.
- */
-public final class MethodBodyDecoderRegistry
-{
-    private static final Logger _log = Logger.getLogger(MethodBodyDecoderRegistry.class);
-
-    private static final Map _classMethodProductToMethodBodyMap = new HashMap();
-
-    static
-    {
-        <xsl:for-each select="registry">
-            <xsl:value-of select="concat(@name, '.register(_classMethodProductToMethodBodyMap)')"/>;         
-        </xsl:for-each>
-    }
-
-    public static AMQMethodBody get(int clazz, int method) throws AMQFrameDecodingException
-    {
-	Class bodyClass = (Class) _classMethodProductToMethodBodyMap.get(new Integer(clazz * 1000 + method));
-	if (bodyClass != null)
-	{
-	    try
-	    {
-	        return (AMQMethodBody) bodyClass.newInstance();
-	    }
-	    catch (Exception e)
-	    {
-	    	throw new AMQFrameDecodingException(_log,
-                    "Unable to instantiate body class for class " + clazz + " and method " + method + ": " + e, e);
-	    }
-	}
-	else
-	{
-	    throw new AMQFrameDecodingException(_log,
-                "Unable to find a suitable decoder for class " + clazz + " and method " + method);
-	}    
-    }
-}
-</xsl:result-document>
-</xsl:template>
-
-<xsl:template match="frames" mode="list-registry">	
-    <xsl:if test="$registry_name">
-
-    <xsl:variable name="file" select="concat($registry_name, '.java')"/> 
-    wrote <xsl:value-of select="$file"/> 
-    <xsl:result-document href="{$file}" format="textFormat">
-    <xsl:value-of select="amq:copyright()"/>
-<!-- package org.apache.qpid.framing_<xsl:value-of select="$major"/>_<xsl:value-of select="$minor"/>; -->
-package org.apache.qpid.framing;
-
-import java.util.Map;
-
-/**
- * This class is autogenerated, do not modify. [From <xsl:value-of select="@protocol"/>]
- */
-class <xsl:value-of select="$registry_name"/>
-{
-    static void register(Map map)
-    {
-        <xsl:for-each select="frame">
-            <xsl:text>map.put(new Integer(</xsl:text>
-            <xsl:value-of select="@class-id"/>         
-	    <xsl:text> * 1000 + </xsl:text> 
-            <xsl:value-of select="@method-id"/>         
-	    <xsl:text>), </xsl:text> 
-            <xsl:value-of select="concat(@name, '.class')"/>);         
-        </xsl:for-each>
-    }
-}
-    </xsl:result-document>
-
-    </xsl:if>
-</xsl:template>
 
 </xsl:stylesheet>



Mime
View raw message