activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r462621 [2/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/BasicReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.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 BasicReturnBody 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)
+    {
+        BasicReturnBody body = new BasicReturnBody();
+        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/ChannelAlertBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.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 ChannelAlertBody extends AMQMethodBody
+{ 
+    public int replyCode;    
+    public String replyText;    
+    public FieldTable details;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" replyCode: ").append(replyCode);
+        buf.append(" replyText: ").append(replyText);
+        buf.append(" details: ").append(details);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, FieldTable details)
+    {
+        ChannelAlertBody body = new ChannelAlertBody();
+        body.replyCode = replyCode;
+        body.replyText = replyText;
+        body.details = details;
+        		 
+        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/ChannelCloseBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.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 ChannelCloseBody extends AMQMethodBody
+{ 
+    public int replyCode;    
+    public String replyText;    
+    public int classId;    
+    public int methodId;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" replyCode: ").append(replyCode);
+        buf.append(" replyText: ").append(replyText);
+        buf.append(" classId: ").append(classId);
+        buf.append(" methodId: ").append(methodId);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId)
+    {
+        ChannelCloseBody body = new ChannelCloseBody();
+        body.replyCode = replyCode;
+        body.replyText = replyText;
+        body.classId = classId;
+        body.methodId = methodId;
+        		 
+        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/ChannelCloseOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.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 ChannelCloseOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        ChannelCloseOkBody body = new ChannelCloseOkBody();
+        		 
+        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/ChannelFlowBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.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 ChannelFlowBody extends AMQMethodBody
+{ 
+    public boolean active;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" active: ").append(active);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, boolean active)
+    {
+        ChannelFlowBody body = new ChannelFlowBody();
+        body.active = active;
+        		 
+        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/ChannelFlowOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.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 ChannelFlowOkBody extends AMQMethodBody
+{ 
+    public boolean active;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" active: ").append(active);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, boolean active)
+    {
+        ChannelFlowOkBody body = new ChannelFlowOkBody();
+        body.active = active;
+        		 
+        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/ChannelOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.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 ChannelOpenBody extends AMQMethodBody
+{ 
+    public String outOfBand;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" outOfBand: ").append(outOfBand);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String outOfBand)
+    {
+        ChannelOpenBody body = new ChannelOpenBody();
+        body.outOfBand = outOfBand;
+        		 
+        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/ChannelOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.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 ChannelOpenOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        ChannelOpenOkBody body = new ChannelOpenOkBody();
+        		 
+        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/ConnectionCloseBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.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 ConnectionCloseBody extends AMQMethodBody
+{ 
+    public int replyCode;    
+    public String replyText;    
+    public int classId;    
+    public int methodId;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" replyCode: ").append(replyCode);
+        buf.append(" replyText: ").append(replyText);
+        buf.append(" classId: ").append(classId);
+        buf.append(" methodId: ").append(methodId);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId)
+    {
+        ConnectionCloseBody body = new ConnectionCloseBody();
+        body.replyCode = replyCode;
+        body.replyText = replyText;
+        body.classId = classId;
+        body.methodId = methodId;
+        		 
+        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/ConnectionCloseOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.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 ConnectionCloseOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        ConnectionCloseOkBody body = new ConnectionCloseOkBody();
+        		 
+        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/ConnectionOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.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 ConnectionOpenBody extends AMQMethodBody
+{ 
+    public String virtualHost;    
+    public String capabilities;    
+    public boolean insist;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" virtualHost: ").append(virtualHost);
+        buf.append(" capabilities: ").append(capabilities);
+        buf.append(" insist: ").append(insist);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String virtualHost, String capabilities, boolean insist)
+    {
+        ConnectionOpenBody body = new ConnectionOpenBody();
+        body.virtualHost = virtualHost;
+        body.capabilities = capabilities;
+        body.insist = insist;
+        		 
+        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/ConnectionOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.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 ConnectionOpenOkBody extends AMQMethodBody
+{ 
+    public String knownHosts;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" knownHosts: ").append(knownHosts);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String knownHosts)
+    {
+        ConnectionOpenOkBody body = new ConnectionOpenOkBody();
+        body.knownHosts = knownHosts;
+        		 
+        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/ConnectionRedirectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.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 ConnectionRedirectBody extends AMQMethodBody
+{ 
+    public String host;    
+    public String knownHosts;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" host: ").append(host);
+        buf.append(" knownHosts: ").append(knownHosts);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String host, String knownHosts)
+    {
+        ConnectionRedirectBody body = new ConnectionRedirectBody();
+        body.host = host;
+        body.knownHosts = knownHosts;
+        		 
+        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/ConnectionSecureBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.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 ConnectionSecureBody extends AMQMethodBody
+{ 
+    public byte[] challenge;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" challenge: ").append(challenge);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, byte[] challenge)
+    {
+        ConnectionSecureBody body = new ConnectionSecureBody();
+        body.challenge = challenge;
+        		 
+        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/ConnectionSecureOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.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 ConnectionSecureOkBody extends AMQMethodBody
+{ 
+    public byte[] response;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" response: ").append(response);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, byte[] response)
+    {
+        ConnectionSecureOkBody body = new ConnectionSecureOkBody();
+        body.response = response;
+        		 
+        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/ConnectionStartBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.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 ConnectionStartBody extends AMQMethodBody
+{ 
+    public short versionMajor;    
+    public short versionMinor;    
+    public FieldTable serverProperties;    
+    public byte[] mechanisms;    
+    public byte[] locales;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" versionMajor: ").append(versionMajor);
+        buf.append(" versionMinor: ").append(versionMinor);
+        buf.append(" serverProperties: ").append(serverProperties);
+        buf.append(" mechanisms: ").append(mechanisms);
+        buf.append(" locales: ").append(locales);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
+    {
+        ConnectionStartBody body = new ConnectionStartBody();
+        body.versionMajor = versionMajor;
+        body.versionMinor = versionMinor;
+        body.serverProperties = serverProperties;
+        body.mechanisms = mechanisms;
+        body.locales = locales;
+        		 
+        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/ConnectionStartOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.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 ConnectionStartOkBody extends AMQMethodBody
+{ 
+    public FieldTable clientProperties;    
+    public String mechanism;    
+    public byte[] response;    
+    public String locale;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" clientProperties: ").append(clientProperties);
+        buf.append(" mechanism: ").append(mechanism);
+        buf.append(" response: ").append(response);
+        buf.append(" locale: ").append(locale);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, FieldTable clientProperties, String mechanism, byte[] response, String locale)
+    {
+        ConnectionStartOkBody body = new ConnectionStartOkBody();
+        body.clientProperties = clientProperties;
+        body.mechanism = mechanism;
+        body.response = response;
+        body.locale = locale;
+        		 
+        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/ConnectionTuneBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.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 ConnectionTuneBody extends AMQMethodBody
+{ 
+    public int channelMax;    
+    public long frameMax;    
+    public int heartbeat;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" channelMax: ").append(channelMax);
+        buf.append(" frameMax: ").append(frameMax);
+        buf.append(" heartbeat: ").append(heartbeat);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int channelMax, long frameMax, int heartbeat)
+    {
+        ConnectionTuneBody body = new ConnectionTuneBody();
+        body.channelMax = channelMax;
+        body.frameMax = frameMax;
+        body.heartbeat = heartbeat;
+        		 
+        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/ConnectionTuneOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.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 ConnectionTuneOkBody extends AMQMethodBody
+{ 
+    public int channelMax;    
+    public long frameMax;    
+    public int heartbeat;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" channelMax: ").append(channelMax);
+        buf.append(" frameMax: ").append(frameMax);
+        buf.append(" heartbeat: ").append(heartbeat);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int channelMax, long frameMax, int heartbeat)
+    {
+        ConnectionTuneOkBody body = new ConnectionTuneOkBody();
+        body.channelMax = channelMax;
+        body.frameMax = frameMax;
+        body.heartbeat = heartbeat;
+        		 
+        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/DtxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.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 DtxSelectBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        DtxSelectBody body = new DtxSelectBody();
+        		 
+        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/DtxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.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 DtxSelectOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        DtxSelectOkBody body = new DtxSelectOkBody();
+        		 
+        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/DtxStartBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.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 DtxStartBody extends AMQMethodBody
+{ 
+    public String dtxIdentifier;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" dtxIdentifier: ").append(dtxIdentifier);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String dtxIdentifier)
+    {
+        DtxStartBody body = new DtxStartBody();
+        body.dtxIdentifier = dtxIdentifier;
+        		 
+        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/DtxStartOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.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 DtxStartOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        DtxStartOkBody body = new DtxStartOkBody();
+        		 
+        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/ExchangeDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.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.command;
+
+import org.apache.activemq.qpid.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ExchangeDeclareBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String exchange;    
+    public String type;    
+    public boolean passive;    
+    public boolean durable;    
+    public boolean autoDelete;    
+    public boolean internal;    
+    public boolean nowait;    
+    public FieldTable arguments;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" type: ").append(type);
+        buf.append(" passive: ").append(passive);
+        buf.append(" durable: ").append(durable);
+        buf.append(" autoDelete: ").append(autoDelete);
+        buf.append(" internal: ").append(internal);
+        buf.append(" nowait: ").append(nowait);
+        buf.append(" arguments: ").append(arguments);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, String type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
+    {
+        ExchangeDeclareBody body = new ExchangeDeclareBody();
+        body.ticket = ticket;
+        body.exchange = exchange;
+        body.type = type;
+        body.passive = passive;
+        body.durable = durable;
+        body.autoDelete = autoDelete;
+        body.internal = internal;
+        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/ExchangeDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.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 ExchangeDeclareOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        ExchangeDeclareOkBody body = new ExchangeDeclareOkBody();
+        		 
+        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/ExchangeDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.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 ExchangeDeleteBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String exchange;    
+    public boolean ifUnused;    
+    public boolean nowait;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" ticket: ").append(ticket);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" ifUnused: ").append(ifUnused);
+        buf.append(" nowait: ").append(nowait);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, boolean ifUnused, boolean nowait)
+    {
+        ExchangeDeleteBody body = new ExchangeDeleteBody();
+        body.ticket = ticket;
+        body.exchange = exchange;
+        body.ifUnused = ifUnused;
+        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/ExchangeDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.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 ExchangeDeleteOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        ExchangeDeleteOkBody body = new ExchangeDeleteOkBody();
+        		 
+        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/FileAckBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.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 FileAckBody extends AMQMethodBody
+{ 
+    public long deliveryTag;    
+    public boolean multiple;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" deliveryTag: ").append(deliveryTag);
+        buf.append(" multiple: ").append(multiple);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean multiple)
+    {
+        FileAckBody body = new FileAckBody();
+        body.deliveryTag = deliveryTag;
+        body.multiple = multiple;
+        		 
+        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/FileCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.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 FileCancelBody 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)
+    {
+        FileCancelBody body = new FileCancelBody();
+        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/FileCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.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 FileCancelOkBody 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)
+    {
+        FileCancelOkBody body = new FileCancelOkBody();
+        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/FileConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,67 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*    http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+    
+package org.apache.activemq.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 FileConsumeBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String queue;    
+    public String consumerTag;    
+    public boolean noLocal;    
+    public boolean noAck;    
+    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(" noAck: ").append(noAck);
+        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 noAck, boolean exclusive, boolean nowait)
+    {
+        FileConsumeBody body = new FileConsumeBody();
+        body.ticket = ticket;
+        body.queue = queue;
+        body.consumerTag = consumerTag;
+        body.noLocal = noLocal;
+        body.noAck = noAck;
+        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/FileConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.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 FileConsumeOkBody 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)
+    {
+        FileConsumeOkBody body = new FileConsumeOkBody();
+        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/FileDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.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 FileDeliverBody extends AMQMethodBody
+{ 
+    public String consumerTag;    
+    public long deliveryTag;    
+    public boolean redelivered;    
+    public String exchange;    
+    public String routingKey;    
+    public String identifier;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" consumerTag: ").append(consumerTag);
+        buf.append(" deliveryTag: ").append(deliveryTag);
+        buf.append(" redelivered: ").append(redelivered);
+        buf.append(" exchange: ").append(exchange);
+        buf.append(" routingKey: ").append(routingKey);
+        buf.append(" identifier: ").append(identifier);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String consumerTag, long deliveryTag, boolean redelivered, String exchange, String routingKey, String identifier)
+    {
+        FileDeliverBody body = new FileDeliverBody();
+        body.consumerTag = consumerTag;
+        body.deliveryTag = deliveryTag;
+        body.redelivered = redelivered;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        body.identifier = identifier;
+        		 
+        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/FileOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.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 FileOpenBody extends AMQMethodBody
+{ 
+    public String identifier;    
+    public long contentSize;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" identifier: ").append(identifier);
+        buf.append(" contentSize: ").append(contentSize);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, String identifier, long contentSize)
+    {
+        FileOpenBody body = new FileOpenBody();
+        body.identifier = identifier;
+        body.contentSize = contentSize;
+        		 
+        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/FileOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.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 FileOpenOkBody extends AMQMethodBody
+{ 
+    public long stagedSize;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" stagedSize: ").append(stagedSize);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long stagedSize)
+    {
+        FileOpenOkBody body = new FileOpenOkBody();
+        body.stagedSize = stagedSize;
+        		 
+        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/FilePublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.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 FilePublishBody extends AMQMethodBody
+{ 
+    public int ticket;    
+    public String exchange;    
+    public String routingKey;    
+    public boolean mandatory;    
+    public boolean immediate;    
+    public String identifier;    
+     
+
+    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);
+        buf.append(" identifier: ").append(identifier);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, String routingKey, boolean mandatory, boolean immediate, String identifier)
+    {
+        FilePublishBody body = new FilePublishBody();
+        body.ticket = ticket;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        body.mandatory = mandatory;
+        body.immediate = immediate;
+        body.identifier = identifier;
+        		 
+        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/FileQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.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 FileQosBody extends AMQMethodBody
+{ 
+    public long prefetchSize;    
+    public int prefetchCount;    
+    public boolean global;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" prefetchSize: ").append(prefetchSize);
+        buf.append(" prefetchCount: ").append(prefetchCount);
+        buf.append(" global: ").append(global);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long prefetchSize, int prefetchCount, boolean global)
+    {
+        FileQosBody body = new FileQosBody();
+        body.prefetchSize = prefetchSize;
+        body.prefetchCount = prefetchCount;
+        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/FileQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.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 FileQosOkBody extends AMQMethodBody
+{ 
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId)
+    {
+        FileQosOkBody body = new FileQosOkBody();
+        		 
+        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/FileRejectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.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 FileRejectBody extends AMQMethodBody
+{ 
+    public long deliveryTag;    
+    public boolean requeue;    
+     
+
+    public String toString()
+    {
+        StringBuffer buf = new StringBuffer(super.toString());
+        buf.append(" deliveryTag: ").append(deliveryTag);
+        buf.append(" requeue: ").append(requeue);
+         
+        return buf.toString();
+    }
+
+    public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean requeue)
+    {
+        FileRejectBody body = new FileRejectBody();
+        body.deliveryTag = deliveryTag;
+        body.requeue = requeue;
+        		 
+        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/FileReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.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 FileReturnBody 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)
+    {
+        FileReturnBody body = new FileReturnBody();
+        body.replyCode = replyCode;
+        body.replyText = replyText;
+        body.exchange = exchange;
+        body.routingKey = routingKey;
+        		 
+        AMQFrame frame = new AMQFrame();
+        frame.channel = channelId;
+        frame.bodyFrame = body;
+        return frame;
+    }
+} 



Mime
View raw message