activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
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 GMT
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 @@
  -->
 <project name="AMQ Common" default="build">
 
-  <property name="target.src.dir" value="${basedir}/src/main"/>
+    <property name="target.src.dir" value="${basedir}/src/main/java"/>
 
   <macrodef name="saxon">
     <attribute name="out"/>

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>...
+    //    {a=1}
+    //    Parsing <a=2 c=3>...
+    //    {a=2, c=3}
+    //    Parsing <a=3 c=4 d>...
+    //    {a=3, c=4, d=null}
+    //    Parsing <a='four' b='five'>...
+    //    {a=four, b=five}
+    //    Parsing <a=bad>...
+    //    java.lang.IllegalArgumentException: a: Invalid integer in <bad> from <a=bad>.
+    //
+    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;
+    }
+} 



Mime
View raw message