Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 67177 invoked from network); 10 Oct 2006 22:44:25 -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:25 -0000 Received: (qmail 6067 invoked by uid 500); 10 Oct 2006 22:44:25 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 5988 invoked by uid 500); 10 Oct 2006 22:44:24 -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 5957 invoked by uid 99); 10 Oct 2006 22:44:24 -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:24 -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:17 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 5EAEC1A981A; 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 [1/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.5EAEC1A981A@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: Tue Oct 10 15:43:45 2006 New Revision: 462621 URL: http://svn.apache.org/viewvc?view=rev&rev=462621 Log: The generators are now producing code that compiles Added: incubator/activemq/sandbox/qpid/src/main/java/ incubator/activemq/sandbox/qpid/src/main/java/org/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/ 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/command/ 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/src/main/java/org/apache/activemq/qpid/marshaller/ 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/marshaller/v8_0/AccessRequestBodyMarshaller.java 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/marshaller/v8_0/BasicAckBodyMarshaller.java 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/marshaller/v8_0/BasicCancelOkBodyMarshaller.java 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/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java 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/marshaller/v8_0/BasicGetBodyMarshaller.java 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/marshaller/v8_0/BasicGetOkBodyMarshaller.java 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/marshaller/v8_0/BasicQosBodyMarshaller.java 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/marshaller/v8_0/BasicRecoverBodyMarshaller.java 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/marshaller/v8_0/BasicReturnBodyMarshaller.java 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/marshaller/v8_0/ChannelCloseBodyMarshaller.java 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/marshaller/v8_0/ChannelFlowBodyMarshaller.java 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/marshaller/v8_0/ChannelOpenBodyMarshaller.java 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/marshaller/v8_0/ConnectionCloseBodyMarshaller.java 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/marshaller/v8_0/ConnectionOpenBodyMarshaller.java 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/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java 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/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java 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/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java 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/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java 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/marshaller/v8_0/DtxSelectOkBodyMarshaller.java 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/marshaller/v8_0/DtxStartOkBodyMarshaller.java 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/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java 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/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java 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/marshaller/v8_0/FileCancelBodyMarshaller.java 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/marshaller/v8_0/FileConsumeBodyMarshaller.java 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/marshaller/v8_0/FileDeliverBodyMarshaller.java 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/marshaller/v8_0/FileOpenOkBodyMarshaller.java 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/marshaller/v8_0/FileQosBodyMarshaller.java 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/marshaller/v8_0/FileRejectBodyMarshaller.java 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/marshaller/v8_0/FileStageBodyMarshaller.java 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/marshaller/v8_0/QueueBindBodyMarshaller.java 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/marshaller/v8_0/QueueDeclareBodyMarshaller.java 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/marshaller/v8_0/QueueDeleteBodyMarshaller.java 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/marshaller/v8_0/QueuePurgeBodyMarshaller.java 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/marshaller/v8_0/StreamCancelBodyMarshaller.java 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/marshaller/v8_0/StreamConsumeBodyMarshaller.java 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/marshaller/v8_0/StreamDeliverBodyMarshaller.java 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/marshaller/v8_0/StreamQosBodyMarshaller.java 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/marshaller/v8_0/StreamReturnBodyMarshaller.java 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/marshaller/v8_0/TestContentOkBodyMarshaller.java 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/marshaller/v8_0/TestIntegerOkBodyMarshaller.java 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/marshaller/v8_0/TestStringOkBodyMarshaller.java 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/marshaller/v8_0/TestTableOkBodyMarshaller.java 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/marshaller/v8_0/TxCommitBodyMarshaller.java 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/marshaller/v8_0/TxRollbackBodyMarshaller.java 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/marshaller/v8_0/TxSelectBodyMarshaller.java incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java Modified: incubator/activemq/sandbox/qpid/build.xml incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl incubator/activemq/sandbox/qpid/stylesheets/utils.xsl Modified: incubator/activemq/sandbox/qpid/build.xml URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/build.xml?view=diff&rev=462621&r1=462620&r2=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/build.xml (original) +++ incubator/activemq/sandbox/qpid/build.xml Tue Oct 10 15:43:45 2006 @@ -17,7 +17,7 @@ --> - + Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,45 @@ +/* + * + * 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; + + +public class AMQFrame +{ + public int channel; + public AMQMethodBody bodyFrame; + + public AMQFrame() + { + } + + public AMQFrame(int channel, AMQMethodBody bodyFrame) + { + this.channel = channel; + this.bodyFrame = bodyFrame; + } + +// public long getSize() +// { +// return 1 + 2 + 4 + bodyFrame.getSize() + 1; +// } + + public String toString() + { + return "Frame channelId: " + channel + ", bodyFrame: " + String.valueOf(bodyFrame); + } +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,23 @@ +/* + * + * 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; + +public abstract class AMQMethodBody +{ + +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/* + * + * 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; + +import java.io.DataInput; +import java.io.DataOutput; +import java.io.IOException; + +public abstract class AMQMethodBodyMarshaller +{ + + protected int getSize(AMQMethodBody o) + { + return 2 + 2 + getBodySize(o); + } + + protected void writePayload(DataOutput buffer, AMQMethodBody object) throws IOException + { + EncodingUtils.writeUnsignedShort(buffer, getClazz()); + EncodingUtils.writeUnsignedShort(buffer, getMethod()); + writeMethodPayload(buffer, object); + } + + protected void populateFromBuffer(DataInput buffer, long size, AMQMethodBody object) throws IOException + { + populateMethodBodyFromBuffer(buffer, object); + } + + protected abstract int getBodySize(AMQMethodBody o); + protected abstract int getClazz(); + protected abstract int getMethod(); + protected abstract void writeMethodPayload(DataOutput buffer, AMQMethodBody object) throws IOException; + protected abstract void populateMethodBodyFromBuffer(DataInput buffer, AMQMethodBody object) throws IOException; +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,684 @@ +/* + * + * 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; + +import java.io.DataInput; +import java.io.DataOutput; +import java.io.IOException; +import java.nio.charset.Charset; +import java.util.Iterator; +import java.util.Map; + +import org.apache.log4j.Logger; + +public class EncodingUtils +{ + private static final Logger _logger = Logger.getLogger(EncodingUtils.class); + + private static final String STRING_ENCODING = "iso8859-15"; + private static final Charset _charset = Charset.forName("iso8859-15"); + + public static final int SIZEOF_UNSIGNED_SHORT = 2; + public static final int SIZEOF_UNSIGNED_INT = 4; + + public static int encodedShortStringLength(String s) + { + if (s == null) + { + return 1; + } + else + { + return (short) (1 + s.length()); + } + } + + public static int encodedLongStringLength(String s) + { + if (s == null) + { + return 4; + } + else + { + return 4 + s.length(); + } + } + + public static int encodedLongStringLength(char[] s) + { + if (s == null) + { + return 4; + } + else + { + return 4 + s.length; + } + } + + public static int encodedLongstrLength(byte[] bytes) + { + if (bytes == null) + { + return 4; + } + else + { + return 4 + bytes.length; + } + } + + public static int encodedFieldTableLength(FieldTable table) + { + if (table == null) + { + return 4; + } + else + { + return (int)getFieldTableSize(table) + 4; + } + } + + + public static void writeShortStringBytes(DataOutput buffer, String s) throws IOException + { + if (s != null) + { + byte[] encodedString = new byte[s.length()]; + char[] cha = s.toCharArray(); + for (int i = 0; i < cha.length; i++) + { + encodedString[i] = (byte) cha[i]; + } + // TODO: check length fits in an unsigned byte + writeUnsignedByte(buffer, (short) encodedString.length); + buffer.write(encodedString); + } + else + { + // really writing out unsigned byte + buffer.writeByte((byte) 0); + } + } + + public static void writeLongStringBytes(DataOutput buffer, String s) throws IOException + { + assert s == null || s.length() <= 0xFFFE; + if (s != null) + { + int len = s.length(); + writeUnsignedInteger(buffer, s.length()); + byte[] encodedString = new byte[len]; + char[] cha = s.toCharArray(); + for (int i = 0; i < cha.length; i++) + { + encodedString[i] = (byte) cha[i]; + } + buffer.write(encodedString); + } + else + { + writeUnsignedInteger(buffer, 0); + } + } + + public static void writeLongStringBytes(DataOutput buffer, char[] s) throws IOException + { + assert s == null || s.length <= 0xFFFE; + if (s != null) + { + int len = s.length; + writeUnsignedInteger(buffer, s.length); + byte[] encodedString = new byte[len]; + for (int i = 0; i < s.length; i++) + { + encodedString[i] = (byte) s[i]; + } + buffer.write(encodedString); + } + else + { + writeUnsignedInteger(buffer, 0); + } + } + + public static void writeLongStringBytes(DataOutput buffer, byte[] bytes) throws IOException + { + assert bytes == null || bytes.length <= 0xFFFE; + if (bytes != null) + { + writeUnsignedInteger(buffer, bytes.length); + buffer.write(bytes); + } + else + { + writeUnsignedInteger(buffer, 0); + } + } + + public static void writeUnsignedByte(DataOutput buffer, short b) throws IOException + { + byte bv = (byte) b; + buffer.writeByte(bv); + } + + public static void writeUnsignedShort(DataOutput buffer, int s) throws IOException + { + // TODO: Is this comparison safe? Do I need to cast RHS to long? + if (s < Short.MAX_VALUE) + { + buffer.writeShort((short) s); + } + else + { + short sv = (short) s; + buffer.writeByte((byte) (0xFF & (sv >> 8))); + buffer.writeByte((byte) (0xFF & sv)); + } + } + + public static void writeUnsignedInteger(DataOutput buffer, long l) throws IOException + { + // TODO: Is this comparison safe? Do I need to cast RHS to long? + if (l < Integer.MAX_VALUE) + { + buffer.writeInt((int) l); + } + else + { + int iv = (int) l; + + // FIXME: This *may* go faster if we build this into a local 4-byte array and then + // put the array in a single call. + buffer.writeByte((byte) (0xFF & (iv >> 24))); + buffer.writeByte((byte) (0xFF & (iv >> 16))); + buffer.writeByte((byte) (0xFF & (iv >> 8))); + buffer.writeByte((byte) (0xFF & iv)); + } + } + + public static void writeFieldTableBytes(DataOutput buffer, FieldTable table) throws IOException + { + if (table != null) + { + writeFieldTable(buffer, table); + } + else + { + writeUnsignedInteger(buffer, 0); + } + } + + public static void writeBooleans(DataOutput buffer, boolean[] values) throws IOException + { + byte packedValue = 0; + for (int i = 0; i < values.length; i++) + { + if (values[i]) + { + packedValue = (byte) (packedValue | (1 << i)); + } + } + + buffer.writeByte(packedValue); + } + + /** + * This is used for writing longstrs. + * @param buffer + * @param data + * @throws IOException + */ + public static void writeLongstr(DataOutput buffer, byte[] data) throws IOException + { + if (data != null) + { + writeUnsignedInteger(buffer, data.length); + buffer.write(data); + } + else + { + writeUnsignedInteger(buffer, 0); + } + } + + public static void writeTimestamp(DataOutput buffer, long timestamp) throws IOException + { + writeUnsignedInteger(buffer, 0/*timestamp msb*/); + writeUnsignedInteger(buffer, timestamp); + } + + public static boolean[] readBooleans(DataInput buffer) throws IOException + { + byte packedValue = buffer.readByte(); + boolean[] result = new boolean[8]; + + for (int i = 0; i < 8; i++) + { + result[i] = ((packedValue & (1 << i)) != 0); + } + return result; + } + + public static FieldTable readFieldTable(DataInput buffer) throws IOException + { + long length = readUnsignedInteger(buffer); + if (length == 0) + { + return null; + } + else + { + FieldTable table = new FieldTable(); + readFieldTable(buffer, length, table); + return table; + } + } + + + public static short readUnsignedByte(DataInput buffer) throws IOException + { + return (short)(buffer.readByte() & 0xFF); + } + + public static int readUnsignedShort(DataInput buffer) throws IOException + { + return (int)( + ((buffer.readByte() & 0xFF)<<8) | + ((buffer.readByte() & 0xFF)) + ); + } + + public static long readUnsignedInteger(DataInput buffer) throws IOException + { + return (long)( + ((buffer.readByte() & 0xFF)<<24) | + ((buffer.readByte() & 0xFF)<<16) | + ((buffer.readByte() & 0xFF)<<8) | + ((buffer.readByte() & 0xFF)) + ); + } + + + public static String readShortString(DataInput buffer) throws IOException + { + short length = readUnsignedByte(buffer); + if (length == 0) + { + return null; + } + else + { + // this may seem rather odd to declare two array but testing has shown + // that constructing a string from a byte array is 5 (five) times slower + // than constructing one from a char array. + // this approach here is valid since we know that all the chars are + // ASCII (0-127) + byte[] stringBytes = new byte[length]; + buffer.readFully(stringBytes, 0, length); + char[] stringChars = new char[length]; + for (int i = 0; i < stringChars.length; i++) + { + stringChars[i] = (char) stringBytes[i]; + } + + return new String(stringChars); + } + } + + public static String readLongString(DataInput buffer) throws IOException + { + long length = readUnsignedInteger(buffer); + if (length == 0) + { + return null; + } + else + { + // this may seem rather odd to declare two array but testing has shown + // that constructing a string from a byte array is 5 (five) times slower + // than constructing one from a char array. + // this approach here is valid since we know that all the chars are + // ASCII (0-127) + byte[] stringBytes = new byte[(int)length]; + buffer.readFully(stringBytes, 0, (int)length); + char[] stringChars = new char[(int)length]; + for (int i = 0; i < stringChars.length; i++) + { + stringChars[i] = (char) stringBytes[i]; + } + return new String(stringChars); + } + } + + public static byte[] readLongstr(DataInput buffer) throws IOException + { + long length = readUnsignedInteger(buffer); + if (length == 0) + { + return null; + } + else + { + byte[] result = new byte[(int)length]; + buffer.readFully(result); + return result; + } + } + + public static long readTimestamp(DataInput buffer) throws IOException + { + // Discard msb from AMQ timestamp + readUnsignedInteger(buffer); + return readUnsignedInteger(buffer); + } + + // Will barf with a NPE on a null input. Not sure whether it should return null or + // an empty field-table (which would be slower - perhaps unnecessarily). + // + // Some sample input and the result output: + // + // Input: "a=1" "a=2 c=3" "a=3 c=4 d" "a='four' b='five'" "a=bad" + // + // Parsing ... + // {a=1} + // Parsing ... + // {a=2, c=3} + // Parsing ... + // {a=3, c=4, d=null} + // Parsing ... + // {a=four, b=five} + // Parsing ... + // java.lang.IllegalArgumentException: a: Invalid integer in from . + // + public static FieldTable createFieldTableFromMessageSelector(String selector) + { + boolean debug = _logger.isDebugEnabled(); + + // TODO: Doesn't support embedded quotes properly. + String[] expressions = selector.split(" +"); + + FieldTable result = new FieldTable(); + + for (int i = 0; i < expressions.length; i++) + { + String expr = expressions[i]; + + if (debug) + { + _logger.debug("Expression = <" + expr + ">"); + } + + int equals = expr.indexOf('='); + + if (equals < 0) + { + // Existence check + result.put("S" + expr.trim(), null); + } + else + { + String key = expr.substring(0, equals).trim(); + String value = expr.substring(equals + 1).trim(); + + if (debug) + { + _logger.debug("Key = <" + key + ">, Value = <" + value + ">"); + } + + if (value.charAt(0) == '\'') + { + if (value.charAt(value.length() - 1) != '\'') + { + throw new IllegalArgumentException(key + ": Missing quote in <" + value + "> from <" + selector + ">."); + } + else + { + value = value.substring(1, value.length() - 1); + + result.put("S" + key, value); + } + } + else + { + try + { + int intValue = Integer.parseInt(value); + result.put("i" + key, value); + } + catch (NumberFormatException e) + { + throw new IllegalArgumentException(key + ": Invalid integer in <" + value + "> from <" + selector + ">."); + + } + } + } + } + + if (debug) + { + _logger.debug("Field-table created from <" + selector + "> is <" + result + ">"); + } + + return (result); + + } + + static byte[] hexToByteArray(String id) + { + // Should check param for null, long enough for this check, upper-case and trailing char + String s = (id.charAt(1) == 'x') ? id.substring(2) : id; // strip 0x + + int len = s.length(); + int byte_len = len / 2; + byte[] b = new byte[byte_len]; + + for (int i = 0; i < byte_len; i++) + { + // fixme: refine these repetitive subscript calcs. + int ch = i * 2; + + byte b1 = Byte.parseByte(s.substring(ch, ch + 1), 16); + byte b2 = Byte.parseByte(s.substring(ch + 1, ch + 2), 16); + + b[i] = (byte) (b1 * 16 + b2); + } + + return (b); + } + + public static char[] convertToHexCharArray(byte[] from) + { + int length = from.length; + char[] result_buff = new char[length * 2 + 2]; + + result_buff[0] = '0'; + result_buff[1] = 'x'; + + int bite; + int dest = 2; + + for (int i = 0; i < length; i++) + { + bite = from[i]; + + if (bite < 0) + { + bite += 256; + } + + result_buff[dest++] = hex_chars[bite >> 4]; + result_buff[dest++] = hex_chars[bite & 0x0f]; + } + + return (result_buff); + } + + public static String convertToHexString(byte[] from) + { + return (new String(convertToHexCharArray(from))); + } + +// public static String convertToHexString(ByteBuffer bb) +// { +// int size = bb.limit(); +// +// byte[] from = new byte[size]; +// +// // Is this not the same. +// //bb.get(from, 0, size); +// for (int i = 0; i < size; i++) +// { +// from[i] = bb.get(i); +// } +// +// return (new String(convertToHexCharArray(from))); +// } + + public static void main(String[] args) + { + for (int i = 0; i < args.length; i++) + { + String selector = args[i]; + + System.err.println("Parsing <" + selector + ">..."); + + try + { + System.err.println(createFieldTableFromMessageSelector(selector)); + } + catch (IllegalArgumentException e) + { + System.err.println(e); + } + } + } + + private static char hex_chars[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'}; + + + /** + * Construct a new field table. + * + * @param buffer the buffer from which to read data. The length byte must be read already + * @param length the length of the field table. Must be > 0. + * @throws AMQFrameDecodingException if there is an error decoding the table + */ + static public void readFieldTable(DataInput buffer, final long length, FieldTable table) throws IOException { + int sizeRead = 0; + while (sizeRead < length) { + final String key = EncodingUtils.readShortString(buffer); + byte iType = buffer.readByte(); + + sizeRead += EncodingUtils.encodedShortStringLength(key)+1; + + final char type = (char) iType; + Object value; + switch (type) + { + case 'S': + value = EncodingUtils.readLongString(buffer); + sizeRead += EncodingUtils.encodedLongStringLength((String)value); + break; + case 'I': + value = new Long(EncodingUtils.readUnsignedInteger(buffer)); + sizeRead += 4; + break; + default: + String msg = "Field '" + key + "' - unsupported field table type: " + type; + // some extra debug information... + msg += " (" + iType + "), length=" + length + ", sizeRead=" + sizeRead + ", totalSize=" + length; + throw new IOException(msg); + } + + // we deliberately want to call put in the parent class since we do + // not need to do the size calculations + table.put(key, value); + } + } + + static public void writeFieldTable(DataOutput buffer, FieldTable table) throws IOException + { + long _encodedSize = getFieldTableSize(table); + // write out the total length, which we have kept up to date as data is added + EncodingUtils.writeUnsignedInteger(buffer, _encodedSize); + final Iterator it = table.entrySet().iterator(); + while (it.hasNext()) + { + Map.Entry me = (Map.Entry) it.next(); + String key = (String) me.getKey(); + + EncodingUtils.writeShortStringBytes(buffer, key); + Object value = me.getValue(); + + if (value instanceof byte[]) + { + buffer.writeByte((byte) 'S'); + EncodingUtils.writeLongstr(buffer, (byte[]) value); + } + else if (value instanceof String) + { + // TODO: look at using proper charset encoder + buffer.writeByte((byte) 'S'); + EncodingUtils.writeLongStringBytes(buffer, (String) value); + } + else if (value instanceof Integer) + { + buffer.writeByte((byte) 'I'); + EncodingUtils.writeUnsignedInteger(buffer, ((Integer) value).longValue()); + } + else if (value instanceof Long) + { + buffer.writeByte((byte) 'I'); + EncodingUtils.writeUnsignedInteger(buffer, ((Long) value).longValue()); + } + else + { + throw new IllegalArgumentException("Key '" + key + "': Unsupported type in field table, type: " + value.getClass()); + } + } + } + + static private long getFieldTableSize(FieldTable table) { + long rc = 0; + for (Iterator iter = table.entrySet().iterator(); iter.hasNext();) { + Map.Entry entry = (Map.Entry) iter.next(); + rc += EncodingUtils.encodedShortStringLength((String) entry + .getKey()); + Object value = entry.getValue(); + + // the extra byte if for the type indicator that is written out + if (value instanceof String) { + rc += 1 + EncodingUtils.encodedLongStringLength((String) value); + } else if (value instanceof char[]) { + rc += 1 + EncodingUtils.encodedLongStringLength((char[]) value); + } else if (value instanceof Integer) { + rc += 1 + 4; + } else if (value instanceof Long) { + rc += 1 + 4; + } else { + throw new IllegalArgumentException("Unsupported type in field table: " + value.getClass()); + } + + } + return rc; + } + +} Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java?view=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,52 @@ +/* + * + * 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; + +import java.util.LinkedHashMap; + +/** + * From the protocol document: + * field-table = short-integer *field-value-pair + * field-value-pair = field-name field-value + * field-name = short-string + * field-value = 'S' long-string + * / 'I' long-integer + * / 'D' decimal-value + * / 'T' long-integer + * decimal-value = decimals long-integer + * decimals = OCTET + */ +public class FieldTable extends LinkedHashMap +{ + + private static final long serialVersionUID = -8656410050815010955L; + + public Object put(Object key, Object value) + { + if (key == null) + { + throw new IllegalArgumentException("All keys must be Strings - was passed: null"); + } + else if (!(key instanceof String)) + { + throw new IllegalArgumentException("All keys must be Strings - was passed: " + key.getClass()); + } + return super.put(key, value); + } + +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class AccessRequestBody extends AMQMethodBody +{ + public String realm; + public boolean exclusive; + public boolean passive; + public boolean active; + public boolean write; + public boolean read; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" realm: ").append(realm); + buf.append(" exclusive: ").append(exclusive); + buf.append(" passive: ").append(passive); + buf.append(" active: ").append(active); + buf.append(" write: ").append(write); + buf.append(" read: ").append(read); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class AccessRequestOkBody extends AMQMethodBody +{ + public int ticket; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" ticket: ").append(ticket); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,52 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicAckBody extends AMQMethodBody +{ + public long deliveryTag; + public boolean multiple; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" deliveryTag: ").append(deliveryTag); + buf.append(" multiple: ").append(multiple); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,52 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicCancelBody extends AMQMethodBody +{ + public String consumerTag; + public boolean nowait; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" consumerTag: ").append(consumerTag); + buf.append(" nowait: ").append(nowait); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicCancelOkBody extends AMQMethodBody +{ + public String consumerTag; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" consumerTag: ").append(consumerTag); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,67 @@ +/** +* +* Copyright (c) 2006 The Apache Software Foundation +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +* +*/ + +package org.apache.activemq.qpid.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicConsumeBody extends AMQMethodBody +{ + public int ticket; + public String queue; + public String consumerTag; + public boolean noLocal; + public boolean noAck; + public boolean exclusive; + public boolean nowait; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" ticket: ").append(ticket); + buf.append(" queue: ").append(queue); + buf.append(" consumerTag: ").append(consumerTag); + buf.append(" noLocal: ").append(noLocal); + buf.append(" noAck: ").append(noAck); + buf.append(" exclusive: ").append(exclusive); + buf.append(" nowait: ").append(nowait); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicConsumeOkBody extends AMQMethodBody +{ + public String consumerTag; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" consumerTag: ").append(consumerTag); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,61 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicDeliverBody extends AMQMethodBody +{ + public String consumerTag; + public long deliveryTag; + public boolean redelivered; + public String exchange; + public String routingKey; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" consumerTag: ").append(consumerTag); + buf.append(" deliveryTag: ").append(deliveryTag); + buf.append(" redelivered: ").append(redelivered); + buf.append(" exchange: ").append(exchange); + buf.append(" routingKey: ").append(routingKey); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,55 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicGetBody extends AMQMethodBody +{ + public int ticket; + public String queue; + public boolean noAck; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" ticket: ").append(ticket); + buf.append(" queue: ").append(queue); + buf.append(" noAck: ").append(noAck); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicGetEmptyBody extends AMQMethodBody +{ + public String clusterId; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" clusterId: ").append(clusterId); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,61 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicGetOkBody extends AMQMethodBody +{ + public long deliveryTag; + public boolean redelivered; + public String exchange; + public String routingKey; + public long messageCount; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" deliveryTag: ").append(deliveryTag); + buf.append(" redelivered: ").append(redelivered); + buf.append(" exchange: ").append(exchange); + buf.append(" routingKey: ").append(routingKey); + buf.append(" messageCount: ").append(messageCount); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,61 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicPublishBody extends AMQMethodBody +{ + public int ticket; + public String exchange; + public String routingKey; + public boolean mandatory; + public boolean immediate; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" ticket: ").append(ticket); + buf.append(" exchange: ").append(exchange); + buf.append(" routingKey: ").append(routingKey); + buf.append(" mandatory: ").append(mandatory); + buf.append(" immediate: ").append(immediate); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,55 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicQosBody extends AMQMethodBody +{ + public long prefetchSize; + public int prefetchCount; + public boolean global; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" prefetchSize: ").append(prefetchSize); + buf.append(" prefetchCount: ").append(prefetchCount); + buf.append(" global: ").append(global); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,46 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicQosOkBody extends AMQMethodBody +{ + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,49 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicRecoverBody extends AMQMethodBody +{ + public boolean requeue; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" requeue: ").append(requeue); + + 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; + } +} Added: 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=auto&rev=462621 ============================================================================== --- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java (added) +++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java Tue Oct 10 15:43:45 2006 @@ -0,0 +1,52 @@ +/** +* +* 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.command; + +import org.apache.activemq.qpid.*; + +/** + * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)] + */ +public class BasicRejectBody extends AMQMethodBody +{ + public long deliveryTag; + public boolean requeue; + + + public String toString() + { + StringBuffer buf = new StringBuffer(super.toString()); + buf.append(" deliveryTag: ").append(deliveryTag); + buf.append(" requeue: ").append(requeue); + + 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; + } +}