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/27 18:19:06 UTC
svn commit: r468441 [3/6] - in /incubator/activemq/sandbox/qpid: ./ specs/
src/main/java/org/apache/activemq/amqp/broker/
src/main/java/org/apache/activemq/amqp/command/
src/main/java/org/apache/activemq/amqp/transport/
src/main/java/org/apache/activem...
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,88 @@
+/**
+ *
+ * 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicConsumeBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicConsumeBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicConsumeBody object = (BasicConsumeBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 1 /*noLocal*/+
+ 0 /*noAck*/+
+ 0 /*exclusive*/+
+ 0 /*nowait*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicConsumeBody object = (BasicConsumeBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.queue);
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noLocal, object.noAck, object.exclusive, object.nowait});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicConsumeBody object = (BasicConsumeBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.queue = EncodingUtils.readShortString(buffer);
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.noLocal = bools[0];
+ object.noAck = bools[1];
+ object.exclusive = bools[2];
+ object.nowait = bools[3];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicConsumeOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicConsumeOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicConsumeOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicDeliverBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicDeliverBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,85 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicDeliverBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 60;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicDeliverBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicDeliverBody object = (BasicDeliverBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 8 /*deliveryTag*/+
+ 1 /*redelivered*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicDeliverBody object = (BasicDeliverBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.redelivered});
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicDeliverBody object = (BasicDeliverBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+ object.deliveryTag = buffer.readLong();
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.redelivered = bools[0];
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.routingKey = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicGetBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 70;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicGetBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicGetBody object = (BasicGetBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ 1 /*noAck*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicGetBody object = (BasicGetBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.queue);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noAck});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicGetBody object = (BasicGetBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.queue = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.noAck = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetEmptyBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetEmptyBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetEmptyBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetEmptyBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicGetEmptyBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 72;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicGetEmptyBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.clusterId)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.clusterId);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+ object.clusterId = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicGetOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,85 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicGetOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 71;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicGetOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicGetOkBody object = (BasicGetOkBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*redelivered*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 4 /*messageCount*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicGetOkBody object = (BasicGetOkBody)o;
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.redelivered});
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+ EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicGetOkBody object = (BasicGetOkBody)o;
+ object.deliveryTag = buffer.readLong();
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.redelivered = bools[0];
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.routingKey = EncodingUtils.readShortString(buffer);
+ object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicPublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicPublishBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicPublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicPublishBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,84 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicPublishBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 40;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicPublishBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicPublishBody object = (BasicPublishBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 1 /*mandatory*/+
+ 0 /*immediate*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicPublishBody object = (BasicPublishBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.mandatory, object.immediate});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicPublishBody object = (BasicPublishBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.routingKey = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.mandatory = bools[0];
+ object.immediate = bools[1];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicQosBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicQosBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicQosBody object = (BasicQosBody)o;
+
+ return
+ 4 /*prefetchSize*/+
+ 2 /*prefetchCount*/+
+ 1 /*global*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicQosBody object = (BasicQosBody)o;
+ EncodingUtils.writeUnsignedInteger(buffer, object.prefetchSize);
+ EncodingUtils.writeUnsignedShort(buffer, object.prefetchCount);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.global});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicQosBody object = (BasicQosBody)o;
+ object.prefetchSize = EncodingUtils.readUnsignedInteger(buffer);
+ object.prefetchCount = EncodingUtils.readUnsignedShort(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.global = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicQosOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicQosOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicQosOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+ return 0;
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRecoverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRecoverBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRecoverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRecoverBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicRecoverBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 100;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicRecoverBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicRecoverBody object = (BasicRecoverBody)o;
+
+ return
+ 1 /*requeue*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicRecoverBody object = (BasicRecoverBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicRecoverBody object = (BasicRecoverBody)o;
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.requeue = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRejectBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicRejectBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicRejectBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 90;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicRejectBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicRejectBody object = (BasicRejectBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*requeue*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicRejectBody object = (BasicRejectBody)o;
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicRejectBody object = (BasicRejectBody)o;
+ object.deliveryTag = buffer.readLong();
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.requeue = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicReturnBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicReturnBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicReturnBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 50;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new BasicReturnBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ BasicReturnBody object = (BasicReturnBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ BasicReturnBody object = (BasicReturnBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+ EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ BasicReturnBody object = (BasicReturnBody)o;
+ object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+ object.replyText = EncodingUtils.readShortString(buffer);
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.routingKey = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelAlertBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelAlertBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelAlertBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelAlertBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelAlertBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 30;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelAlertBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelAlertBody object = (ChannelAlertBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ EncodingUtils.encodedFieldTableLength(object.details)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelAlertBody object = (ChannelAlertBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+ EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+ EncodingUtils.writeFieldTableBytes(buffer, object.details);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelAlertBody object = (ChannelAlertBody)o;
+ object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+ object.replyText = EncodingUtils.readShortString(buffer);
+ object.details = EncodingUtils.readFieldTable(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelCloseBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 40;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelCloseBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelCloseBody object = (ChannelCloseBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ 2 /*classId*/+
+ 2 /*methodId*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelCloseBody object = (ChannelCloseBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+ EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+ EncodingUtils.writeUnsignedShort(buffer, object.classId);
+ EncodingUtils.writeUnsignedShort(buffer, object.methodId);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelCloseBody object = (ChannelCloseBody)o;
+ object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+ object.replyText = EncodingUtils.readShortString(buffer);
+ object.classId = EncodingUtils.readUnsignedShort(buffer);
+ object.methodId = EncodingUtils.readUnsignedShort(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelCloseOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelCloseOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 41;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelCloseOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+ return 0;
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelFlowBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelFlowBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelFlowBody object = (ChannelFlowBody)o;
+
+ return
+ 1 /*active*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelFlowBody object = (ChannelFlowBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelFlowBody object = (ChannelFlowBody)o;
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.active = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelFlowOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelFlowOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelFlowOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+
+ return
+ 1 /*active*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.active = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelOpenBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelOpenBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.outOfBand)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.outOfBand);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+ object.outOfBand = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ChannelOpenOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ChannelOpenOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ChannelOpenOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+ return 0;
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionCloseBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 60;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionCloseBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionCloseBody object = (ConnectionCloseBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ 2 /*classId*/+
+ 2 /*methodId*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionCloseBody object = (ConnectionCloseBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.replyCode);
+ EncodingUtils.writeShortStringBytes(buffer, object.replyText);
+ EncodingUtils.writeUnsignedShort(buffer, object.classId);
+ EncodingUtils.writeUnsignedShort(buffer, object.methodId);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionCloseBody object = (ConnectionCloseBody)o;
+ object.replyCode = EncodingUtils.readUnsignedShort(buffer);
+ object.replyText = EncodingUtils.readShortString(buffer);
+ object.classId = EncodingUtils.readUnsignedShort(buffer);
+ object.methodId = EncodingUtils.readUnsignedShort(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionCloseOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionCloseOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 61;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionCloseOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+ return 0;
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionOpenBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 40;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionOpenBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionOpenBody object = (ConnectionOpenBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.virtualHost)+
+ EncodingUtils.encodedShortStringLength(object.capabilities)+
+ 1 /*insist*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionOpenBody object = (ConnectionOpenBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.virtualHost);
+ EncodingUtils.writeShortStringBytes(buffer, object.capabilities);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.insist});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionOpenBody object = (ConnectionOpenBody)o;
+ object.virtualHost = EncodingUtils.readShortString(buffer);
+ object.capabilities = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.insist = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionOpenOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionOpenOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 41;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionOpenOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.knownHosts)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+ object.knownHosts = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionRedirectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionRedirectBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionRedirectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionRedirectBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionRedirectBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 50;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionRedirectBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.host)+
+ EncodingUtils.encodedShortStringLength(object.knownHosts)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.host);
+ EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+ object.host = EncodingUtils.readShortString(buffer);
+ object.knownHosts = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionSecureBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionSecureBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+
+ return
+ 4 + (object.challenge == null ? 0 : object.challenge.length)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+ EncodingUtils.writeLongstr(buffer, object.challenge);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+ object.challenge = EncodingUtils.readLongstr(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionSecureOkBodyMarshaller.java Fri Oct 27 09:18:49 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.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionSecureOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionSecureOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+
+ return
+ 4 + (object.response == null ? 0 : object.response.length)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+ EncodingUtils.writeLongstr(buffer, object.response);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+ object.response = EncodingUtils.readLongstr(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,85 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionStartBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionStartBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionStartBody object = (ConnectionStartBody)o;
+
+ return
+ 1 /*versionMajor*/+
+ 1 /*versionMinor*/+
+ EncodingUtils.encodedFieldTableLength(object.serverProperties)+
+ 4 + (object.mechanisms == null ? 0 : object.mechanisms.length)+
+ 4 + (object.locales == null ? 0 : object.locales.length)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionStartBody object = (ConnectionStartBody)o;
+ EncodingUtils.writeUnsignedByte(buffer, object.versionMajor);
+ EncodingUtils.writeUnsignedByte(buffer, object.versionMinor);
+ EncodingUtils.writeFieldTableBytes(buffer, object.serverProperties);
+ EncodingUtils.writeLongstr(buffer, object.mechanisms);
+ EncodingUtils.writeLongstr(buffer, object.locales);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionStartBody object = (ConnectionStartBody)o;
+ object.versionMajor = EncodingUtils.readUnsignedByte(buffer);
+ object.versionMinor = EncodingUtils.readUnsignedByte(buffer);
+ object.serverProperties = EncodingUtils.readFieldTable(buffer);
+ object.mechanisms = EncodingUtils.readLongstr(buffer);
+ object.locales = EncodingUtils.readLongstr(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionStartOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,82 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionStartOkBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionStartOkBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+
+ return
+ EncodingUtils.encodedFieldTableLength(object.clientProperties)+
+ EncodingUtils.encodedShortStringLength(object.mechanism)+
+ 4 + (object.response == null ? 0 : object.response.length)+
+ EncodingUtils.encodedShortStringLength(object.locale)
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+ EncodingUtils.writeFieldTableBytes(buffer, object.clientProperties);
+ EncodingUtils.writeShortStringBytes(buffer, object.mechanism);
+ EncodingUtils.writeLongstr(buffer, object.response);
+ EncodingUtils.writeShortStringBytes(buffer, object.locale);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionStartOkBody object = (ConnectionStartOkBody)o;
+ object.clientProperties = EncodingUtils.readFieldTable(buffer);
+ object.mechanism = EncodingUtils.readShortString(buffer);
+ object.response = EncodingUtils.readLongstr(buffer);
+ object.locale = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionTuneBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionTuneBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionTuneBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/ConnectionTuneBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class ConnectionTuneBodyMarshaller extends MethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 30;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public MethodBody createBody() {
+ return new ConnectionTuneBody();
+ }
+
+ protected int getBodySize(MethodBody o)
+ {
+ ConnectionTuneBody object = (ConnectionTuneBody)o;
+
+ return
+ 2 /*channelMax*/+
+ 4 /*frameMax*/+
+ 2 /*heartbeat*/
+ ;
+
+ }
+
+ public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+ {
+ ConnectionTuneBody object = (ConnectionTuneBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.channelMax);
+ EncodingUtils.writeUnsignedInteger(buffer, object.frameMax);
+ EncodingUtils.writeUnsignedShort(buffer, object.heartbeat);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+ {
+ ConnectionTuneBody object = (ConnectionTuneBody)o;
+ object.channelMax = EncodingUtils.readUnsignedShort(buffer);
+ object.frameMax = EncodingUtils.readUnsignedInteger(buffer);
+ object.heartbeat = EncodingUtils.readUnsignedShort(buffer);
+
+ }
+}