Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 67302 invoked from network); 10 Oct 2006 22:44:46 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 10 Oct 2006 22:44:46 -0000 Received: (qmail 6375 invoked by uid 500); 10 Oct 2006 22:44:46 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 6347 invoked by uid 500); 10 Oct 2006 22:44:46 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 6337 invoked by uid 99); 10 Oct 2006 22:44:46 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Oct 2006 15:44:46 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: local policy) Received: from [140.211.166.113] (HELO eris.apache.org) (140.211.166.113) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Oct 2006 15:44:42 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 8B81E1A9827; Tue, 10 Oct 2006 15:43:56 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r462621 [6/7] - in /incubator/activemq/sandbox/qpid: ./ src/main/java/ src/main/java/org/ src/main/java/org/apache/ src/main/java/org/apache/activemq/ src/main/java/org/apache/activemq/qpid/ src/main/java/org/apache/activemq/qpid/command/ s... Date: Tue, 10 Oct 2006 22:43:51 -0000 To: activemq-commits@geronimo.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20061010224356.8B81E1A9827@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,80 @@ +/** +* +* 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 QueueDeleteBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 50; + public static final int METHOD_ID = 40; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + QueueDeleteBody object = (QueueDeleteBody)o; + + return + 2 /*ticket*/+ + EncodingUtils.encodedShortStringLength(object.queue)+ + 1 /*ifUnused*/+ + 0 /*ifEmpty*/+ + 0 /*nowait*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + QueueDeleteBody object = (QueueDeleteBody)o; + EncodingUtils.writeUnsignedShort(buffer, object.ticket); + EncodingUtils.writeShortStringBytes(buffer, object.queue); + EncodingUtils.writeBooleans(buffer, new boolean[]{ object.ifUnused, object.ifEmpty, object.nowait}); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + QueueDeleteBody object = (QueueDeleteBody)o; + object.ticket = EncodingUtils.readUnsignedShort(buffer); + object.queue = EncodingUtils.readShortString(buffer); + boolean[] bools = EncodingUtils.readBooleans(buffer);object.ifUnused = bools[0]; + object.ifEmpty = bools[1]; + object.nowait = bools[2]; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.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 QueueDeleteOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 50; + public static final int METHOD_ID = 41; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + QueueDeleteOkBody object = (QueueDeleteOkBody)o; + + return + 4 /*messageCount*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + QueueDeleteOkBody object = (QueueDeleteOkBody)o; + EncodingUtils.writeUnsignedInteger(buffer, object.messageCount); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + QueueDeleteOkBody object = (QueueDeleteOkBody)o; + object.messageCount = EncodingUtils.readUnsignedInteger(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.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 QueuePurgeBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 50; + public static final int METHOD_ID = 30; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + QueuePurgeBody object = (QueuePurgeBody)o; + + return + 2 /*ticket*/+ + EncodingUtils.encodedShortStringLength(object.queue)+ + 1 /*nowait*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + QueuePurgeBody object = (QueuePurgeBody)o; + EncodingUtils.writeUnsignedShort(buffer, object.ticket); + EncodingUtils.writeShortStringBytes(buffer, object.queue); + EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait}); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + QueuePurgeBody object = (QueuePurgeBody)o; + object.ticket = EncodingUtils.readUnsignedShort(buffer); + object.queue = 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/QueuePurgeOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeOkBodyMarshaller.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 QueuePurgeOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 50; + public static final int METHOD_ID = 31; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + QueuePurgeOkBody object = (QueuePurgeOkBody)o; + + return + 4 /*messageCount*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + QueuePurgeOkBody object = (QueuePurgeOkBody)o; + EncodingUtils.writeUnsignedInteger(buffer, object.messageCount); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + QueuePurgeOkBody object = (QueuePurgeOkBody)o; + object.messageCount = EncodingUtils.readUnsignedInteger(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.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 StreamCancelBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 30; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamCancelBody object = (StreamCancelBody)o; + + return + EncodingUtils.encodedShortStringLength(object.consumerTag)+ + 1 /*nowait*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamCancelBody object = (StreamCancelBody)o; + EncodingUtils.writeShortStringBytes(buffer, object.consumerTag); + EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait}); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamCancelBody object = (StreamCancelBody)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/StreamCancelOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelOkBodyMarshaller.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 StreamCancelOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 31; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamCancelOkBody object = (StreamCancelOkBody)o; + + return + EncodingUtils.encodedShortStringLength(object.consumerTag) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamCancelOkBody object = (StreamCancelOkBody)o; + EncodingUtils.writeShortStringBytes(buffer, object.consumerTag); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamCancelOkBody object = (StreamCancelOkBody)o; + object.consumerTag = EncodingUtils.readShortString(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,83 @@ +/** +* +* 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 StreamConsumeBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 20; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamConsumeBody object = (StreamConsumeBody)o; + + return + 2 /*ticket*/+ + EncodingUtils.encodedShortStringLength(object.queue)+ + EncodingUtils.encodedShortStringLength(object.consumerTag)+ + 1 /*noLocal*/+ + 0 /*exclusive*/+ + 0 /*nowait*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamConsumeBody object = (StreamConsumeBody)o; + EncodingUtils.writeUnsignedShort(buffer, object.ticket); + EncodingUtils.writeShortStringBytes(buffer, object.queue); + EncodingUtils.writeShortStringBytes(buffer, object.consumerTag); + EncodingUtils.writeBooleans(buffer, new boolean[]{ object.noLocal, object.exclusive, object.nowait}); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamConsumeBody object = (StreamConsumeBody)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.exclusive = bools[1]; + object.nowait = bools[2]; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.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 StreamConsumeOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 21; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamConsumeOkBody object = (StreamConsumeOkBody)o; + + return + EncodingUtils.encodedShortStringLength(object.consumerTag) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamConsumeOkBody object = (StreamConsumeOkBody)o; + EncodingUtils.writeShortStringBytes(buffer, object.consumerTag); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamConsumeOkBody object = (StreamConsumeOkBody)o; + object.consumerTag = EncodingUtils.readShortString(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.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 StreamDeliverBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 60; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamDeliverBody object = (StreamDeliverBody)o; + + return + EncodingUtils.encodedShortStringLength(object.consumerTag)+ + 8 /*deliveryTag*/+ + EncodingUtils.encodedShortStringLength(object.exchange)+ + EncodingUtils.encodedShortStringLength(object.queue) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamDeliverBody object = (StreamDeliverBody)o; + EncodingUtils.writeShortStringBytes(buffer, object.consumerTag); + buffer.writeLong(object.deliveryTag); + EncodingUtils.writeShortStringBytes(buffer, object.exchange); + EncodingUtils.writeShortStringBytes(buffer, object.queue); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamDeliverBody object = (StreamDeliverBody)o; + object.consumerTag = EncodingUtils.readShortString(buffer); + object.deliveryTag = buffer.readLong(); + object.exchange = EncodingUtils.readShortString(buffer); + object.queue = EncodingUtils.readShortString(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.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 StreamPublishBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 40; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamPublishBody object = (StreamPublishBody)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 + { + StreamPublishBody object = (StreamPublishBody)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 + { + StreamPublishBody object = (StreamPublishBody)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/StreamQosBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.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 StreamQosBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 10; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamQosBody object = (StreamQosBody)o; + + return + 4 /*prefetchSize*/+ + 2 /*prefetchCount*/+ + 4 /*consumeRate*/+ + 1 /*global*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamQosBody object = (StreamQosBody)o; + EncodingUtils.writeUnsignedInteger(buffer, object.prefetchSize); + EncodingUtils.writeUnsignedShort(buffer, object.prefetchCount); + EncodingUtils.writeUnsignedInteger(buffer, object.consumeRate); + EncodingUtils.writeBooleans(buffer, new boolean[]{ object.global}); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamQosBody object = (StreamQosBody)o; + object.prefetchSize = EncodingUtils.readUnsignedInteger(buffer); + object.prefetchCount = EncodingUtils.readUnsignedShort(buffer); + object.consumeRate = EncodingUtils.readUnsignedInteger(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/StreamQosOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosOkBodyMarshaller.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 StreamQosOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 11; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamQosOkBody object = (StreamQosOkBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + StreamQosOkBody object = (StreamQosOkBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + StreamQosOkBody object = (StreamQosOkBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.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 StreamReturnBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 80; + public static final int METHOD_ID = 50; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + StreamReturnBody object = (StreamReturnBody)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 + { + StreamReturnBody object = (StreamReturnBody)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 + { + StreamReturnBody object = (StreamReturnBody)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/TestContentBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentBodyMarshaller.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 TestContentBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 40; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestContentBody object = (TestContentBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestContentBody object = (TestContentBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestContentBody object = (TestContentBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.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 TestContentOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 41; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestContentOkBody object = (TestContentOkBody)o; + + return + 4 /*contentChecksum*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestContentOkBody object = (TestContentOkBody)o; + EncodingUtils.writeUnsignedInteger(buffer, object.contentChecksum); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestContentOkBody object = (TestContentOkBody)o; + object.contentChecksum = EncodingUtils.readUnsignedInteger(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.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 TestIntegerBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 10; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestIntegerBody object = (TestIntegerBody)o; + + return + 1 /*integer1*/+ + 2 /*integer2*/+ + 4 /*integer3*/+ + 8 /*integer4*/+ + 1 /*operation*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestIntegerBody object = (TestIntegerBody)o; + EncodingUtils.writeUnsignedByte(buffer, object.integer1); + EncodingUtils.writeUnsignedShort(buffer, object.integer2); + EncodingUtils.writeUnsignedInteger(buffer, object.integer3); + buffer.writeLong(object.integer4); + EncodingUtils.writeUnsignedByte(buffer, object.operation); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestIntegerBody object = (TestIntegerBody)o; + object.integer1 = EncodingUtils.readUnsignedByte(buffer); + object.integer2 = EncodingUtils.readUnsignedShort(buffer); + object.integer3 = EncodingUtils.readUnsignedInteger(buffer); + object.integer4 = buffer.readLong(); + object.operation = EncodingUtils.readUnsignedByte(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.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 TestIntegerOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 11; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestIntegerOkBody object = (TestIntegerOkBody)o; + + return + 8 /*result*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestIntegerOkBody object = (TestIntegerOkBody)o; + buffer.writeLong(object.result); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestIntegerOkBody object = (TestIntegerOkBody)o; + object.result = buffer.readLong(); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.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 TestStringBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 20; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestStringBody object = (TestStringBody)o; + + return + EncodingUtils.encodedShortStringLength(object.string1)+ + 4 + (object.string2 == null ? 0 : object.string2.length)+ + 1 /*operation*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestStringBody object = (TestStringBody)o; + EncodingUtils.writeShortStringBytes(buffer, object.string1); + EncodingUtils.writeLongstr(buffer, object.string2); + EncodingUtils.writeUnsignedByte(buffer, object.operation); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestStringBody object = (TestStringBody)o; + object.string1 = EncodingUtils.readShortString(buffer); + object.string2 = EncodingUtils.readLongstr(buffer); + object.operation = EncodingUtils.readUnsignedByte(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.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 TestStringOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 21; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestStringOkBody object = (TestStringOkBody)o; + + return + 4 + (object.result == null ? 0 : object.result.length) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestStringOkBody object = (TestStringOkBody)o; + EncodingUtils.writeLongstr(buffer, object.result); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestStringOkBody object = (TestStringOkBody)o; + object.result = EncodingUtils.readLongstr(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.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 TestTableBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 30; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestTableBody object = (TestTableBody)o; + + return + EncodingUtils.encodedFieldTableLength(object.table)+ + 1 /*integerOp*/+ + 1 /*stringOp*/ + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestTableBody object = (TestTableBody)o; + EncodingUtils.writeFieldTableBytes(buffer, object.table); + EncodingUtils.writeUnsignedByte(buffer, object.integerOp); + EncodingUtils.writeUnsignedByte(buffer, object.stringOp); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestTableBody object = (TestTableBody)o; + object.table = EncodingUtils.readFieldTable(buffer); + object.integerOp = EncodingUtils.readUnsignedByte(buffer); + object.stringOp = EncodingUtils.readUnsignedByte(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.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 TestTableOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 120; + public static final int METHOD_ID = 31; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TestTableOkBody object = (TestTableOkBody)o; + + return + 8 /*integerResult*/+ + 4 + (object.stringResult == null ? 0 : object.stringResult.length) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TestTableOkBody object = (TestTableOkBody)o; + buffer.writeLong(object.integerResult); + EncodingUtils.writeLongstr(buffer, object.stringResult); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TestTableOkBody object = (TestTableOkBody)o; + object.integerResult = buffer.readLong(); + object.stringResult = EncodingUtils.readLongstr(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.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 TunnelRequestBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 110; + public static final int METHOD_ID = 10; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TunnelRequestBody object = (TunnelRequestBody)o; + + return + EncodingUtils.encodedFieldTableLength(object.metaData) + ; + + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TunnelRequestBody object = (TunnelRequestBody)o; + EncodingUtils.writeFieldTableBytes(buffer, object.metaData); + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TunnelRequestBody object = (TunnelRequestBody)o; + object.metaData = EncodingUtils.readFieldTable(buffer); + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.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 TxCommitBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 20; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxCommitBody object = (TxCommitBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxCommitBody object = (TxCommitBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxCommitBody object = (TxCommitBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.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 TxCommitOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 21; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxCommitOkBody object = (TxCommitOkBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxCommitOkBody object = (TxCommitOkBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxCommitOkBody object = (TxCommitOkBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.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 TxRollbackBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 30; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxRollbackBody object = (TxRollbackBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxRollbackBody object = (TxRollbackBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxRollbackBody object = (TxRollbackBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.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 TxRollbackOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 31; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxRollbackOkBody object = (TxRollbackOkBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxRollbackOkBody object = (TxRollbackOkBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxRollbackOkBody object = (TxRollbackOkBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.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 TxSelectBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 10; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxSelectBody object = (TxSelectBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxSelectBody object = (TxSelectBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxSelectBody object = (TxSelectBody)o; + + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.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 TxSelectOkBodyMarshaller extends AMQMethodBodyMarshaller +{ + public static final int CLASS_ID = 90; + public static final int METHOD_ID = 11; + + protected int getClazz() + { + return CLASS_ID; + } + + protected int getMethod() + { + return METHOD_ID; + } + + protected int getBodySize(AMQMethodBody o) + { + TxSelectOkBody object = (TxSelectOkBody)o; + return 0; + } + + protected void writeMethodPayload(DataOutput buffer, AMQMethodBody o) throws IOException + { + TxSelectOkBody object = (TxSelectOkBody)o; + + } + + public void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody o) throws IOException + { + TxSelectOkBody object = (TxSelectOkBody)o; + + } +} Modified: incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl?view=diff&rev=462621&r1=462620&r2=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl (original) +++ incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl Tue Oct 10 15:43:45 2006 @@ -24,20 +24,9 @@ - - - - - - - - - - - @@ -57,66 +46,19 @@ package org.apache.activemq.qpid.command; +import org.apache.activemq.qpid.*; + /** * This class is autogenerated, do not modify. [From ] */ -public class extends AMQMethodBody implements EncodableAMQDataBlock +public class extends AMQMethodBody { - public static final int CLASS_ID = ; - public static final int METHOD_ID = ; - public ; - protected int getClazz() - { - return ; - } - - protected int getMethod() - { - return ; - } - - protected int getBodySize() - { - - - return - - + - - - - ; - - return 0; - - } - - protected void writeMethodPayload(ByteBuffer buffer) - { - - - ; - - - EncodingUtils.writeBooleans(buffer, new boolean[]{ - }); - - - } - - public void populateMethodBodyFromBuffer(ByteBuffer buffer) throws AMQFrameDecodingException - { - - ; - - } - public String toString() { StringBuffer buf = new StringBuffer(super.toString()); @@ -139,100 +81,5 @@ } } - - - Matching root for registry mode! - - - - - -Wrote MethodBodyDecoderRegistry.java - - - -package org.apache.qpid.framing; - -import java.util.Map; -import java.util.HashMap; -import org.apache.log4j.Logger; -import org.apache.qpid.AMQException; -import org.apache.qpid.framing.AMQFrameDecodingException; -import org.apache.qpid.framing.AMQMethodBody; - -/** - * This class is autogenerated, do not modify. - */ -public final class MethodBodyDecoderRegistry -{ - private static final Logger _log = Logger.getLogger(MethodBodyDecoderRegistry.class); - - private static final Map _classMethodProductToMethodBodyMap = new HashMap(); - - static - { - - ; - - } - - public static AMQMethodBody get(int clazz, int method) throws AMQFrameDecodingException - { - Class bodyClass = (Class) _classMethodProductToMethodBodyMap.get(new Integer(clazz * 1000 + method)); - if (bodyClass != null) - { - try - { - return (AMQMethodBody) bodyClass.newInstance(); - } - catch (Exception e) - { - throw new AMQFrameDecodingException(_log, - "Unable to instantiate body class for class " + clazz + " and method " + method + ": " + e, e); - } - } - else - { - throw new AMQFrameDecodingException(_log, - "Unable to find a suitable decoder for class " + clazz + " and method " + method); - } - } -} - - - - - - - - wrote - - - -package org.apache.qpid.framing; - -import java.util.Map; - -/** - * This class is autogenerated, do not modify. [From ] - */ -class -{ - static void register(Map map) - { - - map.put(new Integer( - - * 1000 + - - ), - ); - - } -} - - - -