You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/10/11 00:43:51 UTC
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...
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;
+ }
+}