Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 37582 invoked from network); 13 Oct 2006 15:50:07 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 13 Oct 2006 15:50:07 -0000 Received: (qmail 38543 invoked by uid 500); 13 Oct 2006 15:50:06 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 38518 invoked by uid 500); 13 Oct 2006 15:50:06 -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 38418 invoked by uid 99); 13 Oct 2006 15:50:06 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Oct 2006 08:50:06 -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; Fri, 13 Oct 2006 08:49:59 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 838F01A981A; Fri, 13 Oct 2006 08:49:37 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r463716 [1/6] - in /incubator/activemq/sandbox/qpid: ./ src/main/java/org/apache/activemq/qpid/ src/main/java/org/apache/activemq/qpid/command/ src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ src/main/java/org/apache/activemq/qpid/t... Date: Fri, 13 Oct 2006 15:49:30 -0000 To: activemq-commits@geronimo.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20061013154937.838F01A981A@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: chirino Date: Fri Oct 13 08:49:22 2006 New Revision: 463716 URL: http://svn.apache.org/viewvc?view=rev&rev=463716 Log: Getting closer... Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderProperties.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FieldTable.java (contents, props changed) - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/transport/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/transport/QpidTransportFactory.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/EncodingUtils.java (contents, props changed) - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/QpidWireFormat.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/QpidWireFormatFactory.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ - copied from r462626, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/AccessRequestBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/AccessRequestBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/AccessRequestOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/AccessRequestOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicAckBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicAckBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicCancelBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicCancelBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicCancelOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicCancelOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicConsumeBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicConsumeOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicDeliverBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetEmptyBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicPublishBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicQosBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicQosOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicRecoverBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicRejectBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicReturnBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelAlertBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelCloseBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelCloseOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelFlowBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelFlowOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelOpenBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelOpenOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionCloseBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionCloseOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionOpenBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionOpenOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionRedirectBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionSecureBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionSecureOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionStartBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionStartOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionTuneBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionTuneOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxSelectBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxSelectOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxStartBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxStartOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeclareBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeclareOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeleteBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeleteOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileAckBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileCancelBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileCancelOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileConsumeBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileConsumeOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileDeliverBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileOpenBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileOpenOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FilePublishBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileQosBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileQosOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileRejectBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileReturnBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileStageBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/MainRegistry.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/MethodBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueBindBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueBindOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeclareBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeclareOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeleteBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeleteOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueuePurgeBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueuePurgeOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamCancelBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamCancelOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamConsumeBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamConsumeOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamDeliverBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamPublishBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamQosBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamQosOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamReturnBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestContentBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestContentOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestIntegerBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestIntegerOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestStringBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestStringOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestTableBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestTableOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TunnelRequestBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxCommitBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxCommitOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxRollbackBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxRollbackOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxSelectBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxSelectOkBodyMarshaller.java - copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/resources/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/DISCLAIMER.txt incubator/activemq/sandbox/qpid/src/main/resources/META-INF/LICENSE.txt (with props) incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/qpid incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/qpid Removed: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ Modified: incubator/activemq/sandbox/qpid/build.xml incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl Modified: incubator/activemq/sandbox/qpid/build.xml URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/build.xml?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/build.xml (original) +++ incubator/activemq/sandbox/qpid/build.xml Fri Oct 13 08:49:22 2006 @@ -59,8 +59,8 @@ - - + Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class AccessRequestBody extends AMQMethodBody +public class AccessRequestBody extends MethodBody { + + public static final int CLASS_ID = 30; + public static final int METHOD_ID = 10; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String realm; public boolean exclusive; public boolean passive; @@ -45,20 +59,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read) - { - AccessRequestBody body = new AccessRequestBody(); - body.realm = realm; - body.exclusive = exclusive; - body.passive = passive; - body.active = active; - body.write = write; - body.read = read; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class AccessRequestOkBody extends AMQMethodBody +public class AccessRequestOkBody extends MethodBody { + + public static final int CLASS_ID = 30; + public static final int METHOD_ID = 11; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int ticket; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int ticket) - { - AccessRequestOkBody body = new AccessRequestOkBody(); - body.ticket = ticket; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicAckBody extends AMQMethodBody +public class BasicAckBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 80; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public long deliveryTag; public boolean multiple; @@ -37,16 +51,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean multiple) - { - BasicAckBody body = new BasicAckBody(); - body.deliveryTag = deliveryTag; - body.multiple = multiple; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicCancelBody extends AMQMethodBody +public class BasicCancelBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 30; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String consumerTag; public boolean nowait; @@ -37,16 +51,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String consumerTag, boolean nowait) - { - BasicCancelBody body = new BasicCancelBody(); - body.consumerTag = consumerTag; - body.nowait = nowait; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicCancelOkBody extends AMQMethodBody +public class BasicCancelOkBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 31; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String consumerTag; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String consumerTag) - { - BasicCancelOkBody body = new BasicCancelOkBody(); - body.consumerTag = consumerTag; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicConsumeBody extends AMQMethodBody +public class BasicConsumeBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 20; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int ticket; public String queue; public String consumerTag; @@ -47,21 +61,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, String consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait) - { - BasicConsumeBody body = new BasicConsumeBody(); - body.ticket = ticket; - body.queue = queue; - body.consumerTag = consumerTag; - body.noLocal = noLocal; - body.noAck = noAck; - body.exclusive = exclusive; - body.nowait = nowait; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicConsumeOkBody extends AMQMethodBody +public class BasicConsumeOkBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 21; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String consumerTag; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String consumerTag) - { - BasicConsumeOkBody body = new BasicConsumeOkBody(); - body.consumerTag = consumerTag; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicDeliverBody extends AMQMethodBody +public class BasicDeliverBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 60; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String consumerTag; public long deliveryTag; public boolean redelivered; @@ -43,19 +57,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String consumerTag, long deliveryTag, boolean redelivered, String exchange, String routingKey) - { - BasicDeliverBody body = new BasicDeliverBody(); - body.consumerTag = consumerTag; - body.deliveryTag = deliveryTag; - body.redelivered = redelivered; - body.exchange = exchange; - body.routingKey = routingKey; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicGetBody extends AMQMethodBody +public class BasicGetBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 70; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int ticket; public String queue; public boolean noAck; @@ -39,17 +53,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, boolean noAck) - { - BasicGetBody body = new BasicGetBody(); - body.ticket = ticket; - body.queue = queue; - body.noAck = noAck; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicGetEmptyBody extends AMQMethodBody +public class BasicGetEmptyBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 72; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String clusterId; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String clusterId) - { - BasicGetEmptyBody body = new BasicGetEmptyBody(); - body.clusterId = clusterId; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicGetOkBody extends AMQMethodBody +public class BasicGetOkBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 71; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public long deliveryTag; public boolean redelivered; public String exchange; @@ -43,19 +57,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean redelivered, String exchange, String routingKey, long messageCount) - { - BasicGetOkBody body = new BasicGetOkBody(); - body.deliveryTag = deliveryTag; - body.redelivered = redelivered; - body.exchange = exchange; - body.routingKey = routingKey; - body.messageCount = messageCount; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicPublishBody extends AMQMethodBody +public class BasicPublishBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 40; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int ticket; public String exchange; public String routingKey; @@ -43,19 +57,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, String routingKey, boolean mandatory, boolean immediate) - { - BasicPublishBody body = new BasicPublishBody(); - body.ticket = ticket; - body.exchange = exchange; - body.routingKey = routingKey; - body.mandatory = mandatory; - body.immediate = immediate; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicQosBody extends AMQMethodBody +public class BasicQosBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 10; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public long prefetchSize; public int prefetchCount; public boolean global; @@ -39,17 +53,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, long prefetchSize, int prefetchCount, boolean global) - { - BasicQosBody body = new BasicQosBody(); - body.prefetchSize = prefetchSize; - body.prefetchCount = prefetchCount; - body.global = global; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicQosOkBody extends AMQMethodBody +public class BasicQosOkBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 11; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String toString() @@ -33,14 +47,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId) - { - BasicQosOkBody body = new BasicQosOkBody(); - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicRecoverBody extends AMQMethodBody +public class BasicRecoverBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 100; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public boolean requeue; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, boolean requeue) - { - BasicRecoverBody body = new BasicRecoverBody(); - body.requeue = requeue; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicRejectBody extends AMQMethodBody +public class BasicRejectBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 90; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public long deliveryTag; public boolean requeue; @@ -37,16 +51,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean requeue) - { - BasicRejectBody body = new BasicRejectBody(); - body.deliveryTag = deliveryTag; - body.requeue = requeue; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class BasicReturnBody extends AMQMethodBody +public class BasicReturnBody extends MethodBody { + + public static final int CLASS_ID = 60; + public static final int METHOD_ID = 50; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int replyCode; public String replyText; public String exchange; @@ -41,18 +55,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, String exchange, String routingKey) - { - BasicReturnBody body = new BasicReturnBody(); - body.replyCode = replyCode; - body.replyText = replyText; - body.exchange = exchange; - body.routingKey = routingKey; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelAlertBody extends AMQMethodBody +public class ChannelAlertBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 30; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int replyCode; public String replyText; public FieldTable details; @@ -39,17 +53,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, FieldTable details) - { - ChannelAlertBody body = new ChannelAlertBody(); - body.replyCode = replyCode; - body.replyText = replyText; - body.details = details; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelCloseBody extends AMQMethodBody +public class ChannelCloseBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 40; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int replyCode; public String replyText; public int classId; @@ -41,18 +55,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId) - { - ChannelCloseBody body = new ChannelCloseBody(); - body.replyCode = replyCode; - body.replyText = replyText; - body.classId = classId; - body.methodId = methodId; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelCloseOkBody extends AMQMethodBody +public class ChannelCloseOkBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 41; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String toString() @@ -33,14 +47,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId) - { - ChannelCloseOkBody body = new ChannelCloseOkBody(); - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelFlowBody extends AMQMethodBody +public class ChannelFlowBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 20; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public boolean active; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, boolean active) - { - ChannelFlowBody body = new ChannelFlowBody(); - body.active = active; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelFlowOkBody extends AMQMethodBody +public class ChannelFlowOkBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 21; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public boolean active; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, boolean active) - { - ChannelFlowOkBody body = new ChannelFlowOkBody(); - body.active = active; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelOpenBody extends AMQMethodBody +public class ChannelOpenBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 10; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String outOfBand; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String outOfBand) - { - ChannelOpenBody body = new ChannelOpenBody(); - body.outOfBand = outOfBand; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ChannelOpenOkBody extends AMQMethodBody +public class ChannelOpenOkBody extends MethodBody { + + public static final int CLASS_ID = 20; + public static final int METHOD_ID = 11; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String toString() @@ -33,14 +47,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId) - { - ChannelOpenOkBody body = new ChannelOpenOkBody(); - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionCloseBody extends AMQMethodBody +public class ConnectionCloseBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 60; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public int replyCode; public String replyText; public int classId; @@ -41,18 +55,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId) - { - ConnectionCloseBody body = new ConnectionCloseBody(); - body.replyCode = replyCode; - body.replyText = replyText; - body.classId = classId; - body.methodId = methodId; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionCloseOkBody extends AMQMethodBody +public class ConnectionCloseOkBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 61; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String toString() @@ -33,14 +47,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId) - { - ConnectionCloseOkBody body = new ConnectionCloseOkBody(); - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionOpenBody extends AMQMethodBody +public class ConnectionOpenBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 40; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String virtualHost; public String capabilities; public boolean insist; @@ -39,17 +53,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String virtualHost, String capabilities, boolean insist) - { - ConnectionOpenBody body = new ConnectionOpenBody(); - body.virtualHost = virtualHost; - body.capabilities = capabilities; - body.insist = insist; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionOpenOkBody extends AMQMethodBody +public class ConnectionOpenOkBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 41; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String knownHosts; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String knownHosts) - { - ConnectionOpenOkBody body = new ConnectionOpenOkBody(); - body.knownHosts = knownHosts; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionRedirectBody extends AMQMethodBody +public class ConnectionRedirectBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 50; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public String host; public String knownHosts; @@ -37,16 +51,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, String host, String knownHosts) - { - ConnectionRedirectBody body = new ConnectionRedirectBody(); - body.host = host; - body.knownHosts = knownHosts; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + } Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java?view=diff&rev=463716&r1=463715&r2=463716 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java (original) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java Fri Oct 13 08:49:22 2006 @@ -23,8 +23,22 @@ /** * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] */ -public class ConnectionSecureBody extends AMQMethodBody +public class ConnectionSecureBody extends MethodBody { + + public static final int CLASS_ID = 10; + public static final int METHOD_ID = 20; + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + public byte[] challenge; @@ -35,15 +49,5 @@ return buf.toString(); } - - public static AMQFrame createAMQFrame(int channelId, byte[] challenge) - { - ConnectionSecureBody body = new ConnectionSecureBody(); - body.challenge = challenge; - - AMQFrame frame = new AMQFrame(); - frame.channel = channelId; - frame.bodyFrame = body; - return frame; - } + }