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 [5/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/ConnectionTuneOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.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 ConnectionTuneOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 31;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ConnectionTuneOkBody object = (ConnectionTuneOkBody)o;
+
+ return
+ 2 /*channelMax*/+
+ 4 /*frameMax*/+
+ 2 /*heartbeat*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ConnectionTuneOkBody object = (ConnectionTuneOkBody)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
+ {
+ ConnectionTuneOkBody object = (ConnectionTuneOkBody)o;
+ object.channelMax = EncodingUtils.readUnsignedShort(buffer);
+ object.frameMax = EncodingUtils.readUnsignedInteger(buffer);
+ object.heartbeat = EncodingUtils.readUnsignedShort(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.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 DtxSelectBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 100;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ DtxSelectBody object = (DtxSelectBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxSelectBody object = (DtxSelectBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxSelectBody object = (DtxSelectBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.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 DtxSelectOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 100;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ DtxSelectOkBody object = (DtxSelectOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxSelectOkBody object = (DtxSelectOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxSelectOkBody object = (DtxSelectOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.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 DtxStartBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 100;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ DtxStartBody object = (DtxStartBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.dtxIdentifier)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxStartBody object = (DtxStartBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.dtxIdentifier);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxStartBody object = (DtxStartBody)o;
+ object.dtxIdentifier = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.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 DtxStartOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 100;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ DtxStartOkBody object = (DtxStartOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxStartOkBody object = (DtxStartOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ DtxStartOkBody object = (DtxStartOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,90 @@
+/**
+*
+* 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 ExchangeDeclareBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.type)+
+ 1 /*passive*/+
+ 0 /*durable*/+
+ 0 /*autoDelete*/+
+ 0 /*internal*/+
+ 0 /*nowait*/+
+ EncodingUtils.encodedFieldTableLength(object.arguments)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.type);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.passive, object.durable, object.autoDelete, object.internal, object.nowait});
+ EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeclareBody object = (ExchangeDeclareBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.type = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.passive = bools[0];
+ object.durable = bools[1];
+ object.autoDelete = bools[2];
+ object.internal = bools[3];
+ object.nowait = bools[4];
+ object.arguments = EncodingUtils.readFieldTable(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.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 ExchangeDeclareOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeclareOkBody object = (ExchangeDeclareOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,78 @@
+/**
+*
+* 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 ExchangeDeleteBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ 1 /*ifUnused*/+
+ 0 /*nowait*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.ifUnused, object.nowait});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeleteBody object = (ExchangeDeleteBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.exchange = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.ifUnused = bools[0];
+ object.nowait = bools[1];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.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 ExchangeDeleteOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ ExchangeDeleteOkBody object = (ExchangeDeleteOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.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 FileAckBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 90;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileAckBody object = (FileAckBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*multiple*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileAckBody object = (FileAckBody)o;
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.multiple});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileAckBody object = (FileAckBody)o;
+ object.deliveryTag = buffer.readLong();
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.multiple = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.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 FileCancelBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 30;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileCancelBody object = (FileCancelBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 1 /*nowait*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileCancelBody object = (FileCancelBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileCancelBody object = (FileCancelBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.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 FileCancelOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 31;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileCancelOkBody object = (FileCancelOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileCancelOkBody object = (FileCancelOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileCancelOkBody object = (FileCancelOkBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.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 FileConsumeBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileConsumeBody object = (FileConsumeBody)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
+ {
+ FileConsumeBody object = (FileConsumeBody)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
+ {
+ FileConsumeBody object = (FileConsumeBody)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/FileConsumeOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.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 FileConsumeOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileConsumeOkBody object = (FileConsumeOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileConsumeOkBody object = (FileConsumeOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileConsumeOkBody object = (FileConsumeOkBody)o;
+ object.consumerTag = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.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 FileDeliverBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 80;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileDeliverBody object = (FileDeliverBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.consumerTag)+
+ 8 /*deliveryTag*/+
+ 1 /*redelivered*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ EncodingUtils.encodedShortStringLength(object.identifier)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileDeliverBody object = (FileDeliverBody)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);
+ EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileDeliverBody object = (FileDeliverBody)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);
+ object.identifier = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.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 FileOpenBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 40;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileOpenBody object = (FileOpenBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.identifier)+
+ 8 /*contentSize*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileOpenBody object = (FileOpenBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+ buffer.writeLong(object.contentSize);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileOpenBody object = (FileOpenBody)o;
+ object.identifier = EncodingUtils.readShortString(buffer);
+ object.contentSize = buffer.readLong();
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.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 FileOpenOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 41;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileOpenOkBody object = (FileOpenOkBody)o;
+
+ return
+ 8 /*stagedSize*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileOpenOkBody object = (FileOpenOkBody)o;
+ buffer.writeLong(object.stagedSize);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileOpenOkBody object = (FileOpenOkBody)o;
+ object.stagedSize = buffer.readLong();
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java Tue Oct 10 15:43:45 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.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 FilePublishBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 60;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FilePublishBody object = (FilePublishBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 1 /*mandatory*/+
+ 0 /*immediate*/+
+ EncodingUtils.encodedShortStringLength(object.identifier)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FilePublishBody object = (FilePublishBody)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});
+ EncodingUtils.writeShortStringBytes(buffer, object.identifier);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FilePublishBody object = (FilePublishBody)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];
+ object.identifier = EncodingUtils.readShortString(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.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 FileQosBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileQosBody object = (FileQosBody)o;
+
+ return
+ 4 /*prefetchSize*/+
+ 2 /*prefetchCount*/+
+ 1 /*global*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileQosBody object = (FileQosBody)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
+ {
+ FileQosBody object = (FileQosBody)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/FileQosOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.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 FileQosOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileQosOkBody object = (FileQosOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileQosOkBody object = (FileQosOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileQosOkBody object = (FileQosOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.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 FileRejectBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 100;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileRejectBody object = (FileRejectBody)o;
+
+ return
+ 8 /*deliveryTag*/+
+ 1 /*requeue*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileRejectBody object = (FileRejectBody)o;
+ buffer.writeLong(object.deliveryTag);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.requeue});
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileRejectBody object = (FileRejectBody)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/FileReturnBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.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 FileReturnBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 70;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileReturnBody object = (FileReturnBody)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
+ {
+ FileReturnBody object = (FileReturnBody)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
+ {
+ FileReturnBody object = (FileReturnBody)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/FileStageBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.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 FileStageBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 70;
+ public static final int METHOD_ID = 50;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ FileStageBody object = (FileStageBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ FileStageBody object = (FileStageBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ FileStageBody object = (FileStageBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,123 @@
+/**
+*
+* 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.util.Map;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ */
+class MainRegistry
+{
+ static void register(Map map)
+ {
+ map.put(new Integer(10 * 1000 + 10), new ConnectionStartBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 11), new ConnectionStartOkBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 20), new ConnectionSecureBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 21), new ConnectionSecureOkBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 30), new ConnectionTuneBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 31), new ConnectionTuneOkBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 40), new ConnectionOpenBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 41), new ConnectionOpenOkBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 50), new ConnectionRedirectBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 60), new ConnectionCloseBodyMarshaller());
+ map.put(new Integer(10 * 1000 + 61), new ConnectionCloseOkBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 10), new ChannelOpenBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 11), new ChannelOpenOkBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 20), new ChannelFlowBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 21), new ChannelFlowOkBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 30), new ChannelAlertBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 40), new ChannelCloseBodyMarshaller());
+ map.put(new Integer(20 * 1000 + 41), new ChannelCloseOkBodyMarshaller());
+ map.put(new Integer(30 * 1000 + 10), new AccessRequestBodyMarshaller());
+ map.put(new Integer(30 * 1000 + 11), new AccessRequestOkBodyMarshaller());
+ map.put(new Integer(40 * 1000 + 10), new ExchangeDeclareBodyMarshaller());
+ map.put(new Integer(40 * 1000 + 11), new ExchangeDeclareOkBodyMarshaller());
+ map.put(new Integer(40 * 1000 + 20), new ExchangeDeleteBodyMarshaller());
+ map.put(new Integer(40 * 1000 + 21), new ExchangeDeleteOkBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 10), new QueueDeclareBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 11), new QueueDeclareOkBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 20), new QueueBindBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 21), new QueueBindOkBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 30), new QueuePurgeBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 31), new QueuePurgeOkBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 40), new QueueDeleteBodyMarshaller());
+ map.put(new Integer(50 * 1000 + 41), new QueueDeleteOkBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 10), new BasicQosBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 11), new BasicQosOkBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 20), new BasicConsumeBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 21), new BasicConsumeOkBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 30), new BasicCancelBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 31), new BasicCancelOkBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 40), new BasicPublishBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 50), new BasicReturnBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 60), new BasicDeliverBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 70), new BasicGetBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 71), new BasicGetOkBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 72), new BasicGetEmptyBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 80), new BasicAckBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 90), new BasicRejectBodyMarshaller());
+ map.put(new Integer(60 * 1000 + 100), new BasicRecoverBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 10), new FileQosBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 11), new FileQosOkBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 20), new FileConsumeBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 21), new FileConsumeOkBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 30), new FileCancelBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 31), new FileCancelOkBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 40), new FileOpenBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 41), new FileOpenOkBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 50), new FileStageBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 60), new FilePublishBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 70), new FileReturnBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 80), new FileDeliverBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 90), new FileAckBodyMarshaller());
+ map.put(new Integer(70 * 1000 + 100), new FileRejectBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 10), new StreamQosBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 11), new StreamQosOkBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 20), new StreamConsumeBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 21), new StreamConsumeOkBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 30), new StreamCancelBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 31), new StreamCancelOkBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 40), new StreamPublishBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 50), new StreamReturnBodyMarshaller());
+ map.put(new Integer(80 * 1000 + 60), new StreamDeliverBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 10), new TxSelectBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 11), new TxSelectOkBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 20), new TxCommitBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 21), new TxCommitOkBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 30), new TxRollbackBodyMarshaller());
+ map.put(new Integer(90 * 1000 + 31), new TxRollbackOkBodyMarshaller());
+ map.put(new Integer(100 * 1000 + 10), new DtxSelectBodyMarshaller());
+ map.put(new Integer(100 * 1000 + 11), new DtxSelectOkBodyMarshaller());
+ map.put(new Integer(100 * 1000 + 20), new DtxStartBodyMarshaller());
+ map.put(new Integer(100 * 1000 + 21), new DtxStartOkBodyMarshaller());
+ map.put(new Integer(110 * 1000 + 10), new TunnelRequestBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 10), new TestIntegerBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 11), new TestIntegerOkBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 20), new TestStringBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 21), new TestStringOkBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 30), new TestTableBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 31), new TestTableOkBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 40), new TestContentBodyMarshaller());
+ map.put(new Integer(120 * 1000 + 41), new TestContentOkBodyMarshaller());
+
+ }
+}
+
\ No newline at end of file
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.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 QueueBindBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 20;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ QueueBindBody object = (QueueBindBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ EncodingUtils.encodedShortStringLength(object.exchange)+
+ EncodingUtils.encodedShortStringLength(object.routingKey)+
+ 1 /*nowait*/+
+ EncodingUtils.encodedFieldTableLength(object.arguments)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueBindBody object = (QueueBindBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.queue);
+ EncodingUtils.writeShortStringBytes(buffer, object.exchange);
+ EncodingUtils.writeShortStringBytes(buffer, object.routingKey);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+ EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueBindBody object = (QueueBindBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.queue = EncodingUtils.readShortString(buffer);
+ object.exchange = EncodingUtils.readShortString(buffer);
+ object.routingKey = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+ object.arguments = EncodingUtils.readFieldTable(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.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 QueueBindOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 21;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ QueueBindOkBody object = (QueueBindOkBody)o;
+ return 0;
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueBindOkBody object = (QueueBindOkBody)o;
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueBindOkBody object = (QueueBindOkBody)o;
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java Tue Oct 10 15:43:45 2006
@@ -0,0 +1,87 @@
+/**
+*
+* 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 QueueDeclareBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 10;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ QueueDeclareBody object = (QueueDeclareBody)o;
+
+ return
+ 2 /*ticket*/+
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ 1 /*passive*/+
+ 0 /*durable*/+
+ 0 /*exclusive*/+
+ 0 /*autoDelete*/+
+ 0 /*nowait*/+
+ EncodingUtils.encodedFieldTableLength(object.arguments)
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueDeclareBody object = (QueueDeclareBody)o;
+ EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+ EncodingUtils.writeShortStringBytes(buffer, object.queue);
+ EncodingUtils.writeBooleans(buffer, new boolean[]{ object.passive, object.durable, object.exclusive, object.autoDelete, object.nowait});
+ EncodingUtils.writeFieldTableBytes(buffer, object.arguments);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueDeclareBody object = (QueueDeclareBody)o;
+ object.ticket = EncodingUtils.readUnsignedShort(buffer);
+ object.queue = EncodingUtils.readShortString(buffer);
+ boolean[] bools = EncodingUtils.readBooleans(buffer);object.passive = bools[0];
+ object.durable = bools[1];
+ object.exclusive = bools[2];
+ object.autoDelete = bools[3];
+ object.nowait = bools[4];
+ object.arguments = EncodingUtils.readFieldTable(buffer);
+
+ }
+}
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java?view=auto&rev=462621
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.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 QueueDeclareOkBodyMarshaller extends AMQMethodBodyMarshaller
+{
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 11;
+
+ protected int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ protected int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ protected int getBodySize(AMQMethodBody o)
+ {
+ QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+
+ return
+ EncodingUtils.encodedShortStringLength(object.queue)+
+ 4 /*messageCount*/+
+ 4 /*consumerCount*/
+ ;
+
+ }
+
+ protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+ EncodingUtils.writeShortStringBytes(buffer, object.queue);
+ EncodingUtils.writeUnsignedInteger(buffer, object.messageCount);
+ EncodingUtils.writeUnsignedInteger(buffer, object.consumerCount);
+
+ }
+
+ public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException
+ {
+ QueueDeclareOkBody object = (QueueDeclareOkBody)o;
+ object.queue = EncodingUtils.readShortString(buffer);
+ object.messageCount = EncodingUtils.readUnsignedInteger(buffer);
+ object.consumerCount = EncodingUtils.readUnsignedInteger(buffer);
+
+ }
+}