activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r462621 [3/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/command/FileStageBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class FileStageBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        FileStageBody body = new FileStageBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueBindBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public String exchange;    
+    public String routingKey;    
+    public boolean nowait;    
+    public FieldTable arguments;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" queue: ").append(queue);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" routingKey: ").append(routingKey);
+        buf.append(" nowait: ").append(nowait);
+        buf.append(" arguments: ").append(arguments);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, String exchange, String routingKey, boolean nowait, FieldTable arguments)
+    {
+        QueueBindBody body = new QueueBindBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        body.nowait = nowait;
+        body.arguments = arguments;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueBindOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        QueueBindOkBody body = new QueueBindOkBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueDeclareBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public boolean passive;    
+    public boolean durable;    
+    public boolean exclusive;    
+    public boolean autoDelete;    
+    public boolean nowait;    
+    public FieldTable arguments;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" queue: ").append(queue);
+        buf.append(" passive: ").append(passive);
+        buf.append(" durable: ").append(durable);
+        buf.append(" exclusive: ").append(exclusive);
+        buf.append(" autoDelete: ").append(autoDelete);
+        buf.append(" nowait: ").append(nowait);
+        buf.append(" arguments: ").append(arguments);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
+    {
+        QueueDeclareBody body = new QueueDeclareBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.passive = passive;
+        body.durable = durable;
+        body.exclusive = exclusive;
+        body.autoDelete = autoDelete;
+        body.nowait = nowait;
+        body.arguments = arguments;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,55 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueDeclareOkBody extends AMQMethodBody
+{ 
+    public String queue;    
+    public long messageCount;    
+    public long consumerCount;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" queue: ").append(queue);
+        buf.append(" messageCount: ").append(messageCount);
+        buf.append(" consumerCount: ").append(consumerCount);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String queue, long messageCount, long consumerCount)
+    {
+        QueueDeclareOkBody body = new QueueDeclareOkBody();
+        body.queue = queue;
+        body.messageCount = messageCount;
+        body.consumerCount = consumerCount;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,61 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueDeleteBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public boolean ifUnused;    
+    public boolean ifEmpty;    
+    public boolean nowait;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" queue: ").append(queue);
+        buf.append(" ifUnused: ").append(ifUnused);
+        buf.append(" ifEmpty: ").append(ifEmpty);
+        buf.append(" nowait: ").append(nowait);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
+    {
+        QueueDeleteBody body = new QueueDeleteBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.ifUnused = ifUnused;
+        body.ifEmpty = ifEmpty;
+        body.nowait = nowait;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueueDeleteOkBody extends AMQMethodBody
+{ 
+    public long messageCount;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" messageCount: ").append(messageCount);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long messageCount)
+    {
+        QueueDeleteOkBody body = new QueueDeleteOkBody();
+        body.messageCount = messageCount;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,55 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueuePurgeBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public boolean nowait;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" queue: ").append(queue);
+        buf.append(" nowait: ").append(nowait);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, boolean nowait)
+    {
+        QueuePurgeBody body = new QueuePurgeBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.nowait = nowait;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class QueuePurgeOkBody extends AMQMethodBody
+{ 
+    public long messageCount;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" messageCount: ").append(messageCount);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long messageCount)
+    {
+        QueuePurgeOkBody body = new QueuePurgeOkBody();
+        body.messageCount = messageCount;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,52 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamCancelBody extends AMQMethodBody
+{ 
+    public String consumerTag;    
+    public boolean nowait;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" consumerTag: ").append(consumerTag);
+        buf.append(" nowait: ").append(nowait);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String consumerTag, boolean nowait)
+    {
+        StreamCancelBody body = new StreamCancelBody();
+        body.consumerTag = consumerTag;
+        body.nowait = nowait;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamCancelOkBody extends AMQMethodBody
+{ 
+    public String consumerTag;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" consumerTag: ").append(consumerTag);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String consumerTag)
+    {
+        StreamCancelOkBody body = new StreamCancelOkBody();
+        body.consumerTag = consumerTag;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamConsumeBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public String consumerTag;    
+    public boolean noLocal;    
+    public boolean exclusive;    
+    public boolean nowait;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" queue: ").append(queue);
+        buf.append(" consumerTag: ").append(consumerTag);
+        buf.append(" noLocal: ").append(noLocal);
+        buf.append(" exclusive: ").append(exclusive);
+        buf.append(" nowait: ").append(nowait);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, String consumerTag, boolean noLocal, boolean exclusive, boolean nowait)
+    {
+        StreamConsumeBody body = new StreamConsumeBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.consumerTag = consumerTag;
+        body.noLocal = noLocal;
+        body.exclusive = exclusive;
+        body.nowait = nowait;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamConsumeOkBody extends AMQMethodBody
+{ 
+    public String consumerTag;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" consumerTag: ").append(consumerTag);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String consumerTag)
+    {
+        StreamConsumeOkBody body = new StreamConsumeOkBody();
+        body.consumerTag = consumerTag;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,58 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamDeliverBody extends AMQMethodBody
+{ 
+    public String consumerTag;    
+    public long deliveryTag;    
+    public String exchange;    
+    public String queue;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" consumerTag: ").append(consumerTag);
+        buf.append(" deliveryTag: ").append(deliveryTag);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" queue: ").append(queue);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String consumerTag, long deliveryTag, String exchange, String queue)
+    {
+        StreamDeliverBody body = new StreamDeliverBody();
+        body.consumerTag = consumerTag;
+        body.deliveryTag = deliveryTag;
+        body.exchange = exchange;
+        body.queue = queue;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,61 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamPublishBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String exchange;    
+    public String routingKey;    
+    public boolean mandatory;    
+    public boolean immediate;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" routingKey: ").append(routingKey);
+        buf.append(" mandatory: ").append(mandatory);
+        buf.append(" immediate: ").append(immediate);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, String routingKey, boolean mandatory, boolean immediate)
+    {
+        StreamPublishBody body = new StreamPublishBody();
+        body.ticket = ticket;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        body.mandatory = mandatory;
+        body.immediate = immediate;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,58 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamQosBody extends AMQMethodBody
+{ 
+    public long prefetchSize;    
+    public int prefetchCount;    
+    public long consumeRate;    
+    public boolean global;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" prefetchSize: ").append(prefetchSize);
+        buf.append(" prefetchCount: ").append(prefetchCount);
+        buf.append(" consumeRate: ").append(consumeRate);
+        buf.append(" global: ").append(global);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long prefetchSize, int prefetchCount, long consumeRate, boolean global)
+    {
+        StreamQosBody body = new StreamQosBody();
+        body.prefetchSize = prefetchSize;
+        body.prefetchCount = prefetchCount;
+        body.consumeRate = consumeRate;
+        body.global = global;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamQosOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        StreamQosOkBody body = new StreamQosOkBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,58 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class StreamReturnBody extends AMQMethodBody
+{ 
+    public int replyCode;    
+    public String replyText;    
+    public String exchange;    
+    public String routingKey;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" replyCode: ").append(replyCode);
+        buf.append(" replyText: ").append(replyText);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" routingKey: ").append(routingKey);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, String exchange, String routingKey)
+    {
+        StreamReturnBody body = new StreamReturnBody();
+        body.replyCode = replyCode;
+        body.replyText = replyText;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestContentBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TestContentBody body = new TestContentBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestContentOkBody extends AMQMethodBody
+{ 
+    public long contentChecksum;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" contentChecksum: ").append(contentChecksum);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long contentChecksum)
+    {
+        TestContentOkBody body = new TestContentOkBody();
+        body.contentChecksum = contentChecksum;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,61 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestIntegerBody extends AMQMethodBody
+{ 
+    public short integer1;    
+    public int integer2;    
+    public long integer3;    
+    public long integer4;    
+    public short operation;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" integer1: ").append(integer1);
+        buf.append(" integer2: ").append(integer2);
+        buf.append(" integer3: ").append(integer3);
+        buf.append(" integer4: ").append(integer4);
+        buf.append(" operation: ").append(operation);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, short integer1, int integer2, long integer3, long integer4, short operation)
+    {
+        TestIntegerBody body = new TestIntegerBody();
+        body.integer1 = integer1;
+        body.integer2 = integer2;
+        body.integer3 = integer3;
+        body.integer4 = integer4;
+        body.operation = operation;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestIntegerOkBody extends AMQMethodBody
+{ 
+    public long result;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" result: ").append(result);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long result)
+    {
+        TestIntegerOkBody body = new TestIntegerOkBody();
+        body.result = result;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,55 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestStringBody extends AMQMethodBody
+{ 
+    public String string1;    
+    public byte[] string2;    
+    public short operation;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" string1: ").append(string1);
+        buf.append(" string2: ").append(string2);
+        buf.append(" operation: ").append(operation);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String string1, byte[] string2, short operation)
+    {
+        TestStringBody body = new TestStringBody();
+        body.string1 = string1;
+        body.string2 = string2;
+        body.operation = operation;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestStringOkBody extends AMQMethodBody
+{ 
+    public byte[] result;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" result: ").append(result);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, byte[] result)
+    {
+        TestStringOkBody body = new TestStringOkBody();
+        body.result = result;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,55 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestTableBody extends AMQMethodBody
+{ 
+    public FieldTable table;    
+    public short integerOp;    
+    public short stringOp;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" table: ").append(table);
+        buf.append(" integerOp: ").append(integerOp);
+        buf.append(" stringOp: ").append(stringOp);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, FieldTable table, short integerOp, short stringOp)
+    {
+        TestTableBody body = new TestTableBody();
+        body.table = table;
+        body.integerOp = integerOp;
+        body.stringOp = stringOp;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,52 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TestTableOkBody extends AMQMethodBody
+{ 
+    public long integerResult;    
+    public byte[] stringResult;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" integerResult: ").append(integerResult);
+        buf.append(" stringResult: ").append(stringResult);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long integerResult, byte[] stringResult)
+    {
+        TestTableOkBody body = new TestTableOkBody();
+        body.integerResult = integerResult;
+        body.stringResult = stringResult;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,49 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TunnelRequestBody extends AMQMethodBody
+{ 
+    public FieldTable metaData;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" metaData: ").append(metaData);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, FieldTable metaData)
+    {
+        TunnelRequestBody body = new TunnelRequestBody();
+        body.metaData = metaData;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxCommitBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxCommitBody body = new TxCommitBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxCommitOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxCommitOkBody body = new TxCommitOkBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxRollbackBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxRollbackBody body = new TxRollbackBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxRollbackOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxRollbackOkBody body = new TxRollbackOkBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxSelectBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxSelectBody body = new TxSelectBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,46 @@
+/**
+*
+* 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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class TxSelectOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        TxSelectOkBody body = new TxSelectOkBody();
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 

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

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

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



Mime
View raw message