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 [4/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/marshaller/v8_0/BasicConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java Tue Oct 10 15:43:45 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.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicConsumeBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicConsumeBody object = (BasicConsumeBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 1 /*noLocal*/+
+ 0 /*noAck*/+
+ 0 /*exclusive*/+
+ 0 /*nowait*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicConsumeOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicConsumeOkBody object = (BasicConsumeOkBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,82 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicDeliverBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicDeliverBody object = (BasicDeliverBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 8 /*deliveryTag*/+
+ 1 /*redelivered*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,76 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicGetBody object = (BasicGetBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ 1 /*noAck*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetEmptyBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.clusterId)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.clusterId);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicGetEmptyBody object = (BasicGetEmptyBody)o;
+ object.clusterId = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,82 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicGetOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicGetOkBody object = (BasicGetOkBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*redelivered*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 4 /*messageCount*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,81 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicPublishBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicPublishBody object = (BasicPublishBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 1 /*mandatory*/+
+ 0 /*immediate*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,76 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicQosBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicQosBody object = (BasicQosBody)o;
+
+ return
+ 4 /*prefetchSize*/+
+ 2 /*prefetchCount*/+
+ 1 /*global*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicQosOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicQosOkBody object = (BasicQosOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicRecoverBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicRecoverBody object = (BasicRecoverBody)o;
+
+ return
+ 1 /*requeue*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicRecoverBody object = (BasicRecoverBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,73 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicRejectBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicRejectBody object = (BasicRejectBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*requeue*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ BasicRejectBody object = (BasicRejectBody)o;
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,79 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class BasicReturnBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ BasicReturnBody object = (BasicReturnBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ 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, AMQMethodBody 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/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,76 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelAlertBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelAlertBody object = (ChannelAlertBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ EncodingUtils.encodedFieldTableLength(object.details)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,79 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelCloseBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelCloseBody object = (ChannelCloseBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ 2 /*classId*/+
+ 2 /*methodId*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelCloseOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelCloseOkBody object = (ChannelCloseOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelFlowBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelFlowBody object = (ChannelFlowBody)o;
+
+ return
+ 1 /*active*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelFlowBody object = (ChannelFlowBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelFlowOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+
+ return
+ 1 /*active*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelFlowOkBody object = (ChannelFlowOkBody)o;
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.active});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.outOfBand)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.outOfBand);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelOpenBody object = (ChannelOpenBody)o;
+ object.outOfBand = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ChannelOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ChannelOpenOkBody object = (ChannelOpenOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,79 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionCloseBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionCloseBody object = (ConnectionCloseBody)o;
+
+ return
+ 2 /*replyCode*/+
+ EncodingUtils.encodedShortStringLength(object.replyText)+
+ 2 /*classId*/+
+ 2 /*methodId*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,64 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionCloseOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionCloseOkBody object = (ConnectionCloseOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,76 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionOpenBody object = (ConnectionOpenBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.virtualHost)+
+ EncodingUtils.encodedShortStringLength(object.capabilities)+
+ 1 /*insist*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.knownHosts)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionOpenOkBody object = (ConnectionOpenOkBody)o;
+ object.knownHosts = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,73 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionRedirectBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.host)+
+ EncodingUtils.encodedShortStringLength(object.knownHosts)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionRedirectBody object = (ConnectionRedirectBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.host);
+ EncodingUtils.writeShortStringBytes(buffer, object.knownHosts);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody 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/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionSecureBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+
+ return
+ 4 + (object.challenge == null ? 0 : object.challenge.length)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+ EncodingUtils.writeLongstr(buffer, object.challenge);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionSecureBody object = (ConnectionSecureBody)o;
+ object.challenge = EncodingUtils.readLongstr(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,70 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionSecureOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+
+ return
+ 4 + (object.response == null ? 0 : object.response.length)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+ EncodingUtils.writeLongstr(buffer, object.response);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionSecureOkBody object = (ConnectionSecureOkBody)o;
+ object.response = EncodingUtils.readLongstr(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,82 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionStartBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody 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)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,79 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionStartOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody 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)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody 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/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,76 @@
+/**
+*
+* Copyright (c) 2006 The Apache Software Foundation
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+package org.apache.activemq.qpid.marshaller.v8_0;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.qpid.*;
+import org.apache.activemq.qpid.command.*;
+import org.apache.activemq.qpid.marshaller.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+public class ConnectionTuneBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ 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;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionTuneBody object = (ConnectionTuneBody)o;
+
+ return
+ 2 /*channelMax*/+
+ 4 /*frameMax*/+
+ 2 /*heartbeat*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody 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, AMQMethodBody o) throws IOException
+ {
+ ConnectionTuneBody object = (ConnectionTuneBody)o;
+ object.channelMax = EncodingUtils.readUnsignedShort(buffer);
+ object.frameMax = EncodingUtils.readUnsignedInteger(buffer);
+ object.heartbeat = EncodingUtils.readUnsignedShort(buffer);
+
+ }
+}