You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/10/13 17:49:30 UTC
svn commit: r463716 [1/6] - in /incubator/activemq/sandbox/qpid: ./
src/main/java/org/apache/activemq/qpid/
src/main/java/org/apache/activemq/qpid/command/
src/main/java/org/apache/activemq/qpid/marshaller/v8_0/
src/main/java/org/apache/activemq/qpid/t...
Author: chirino
Date: Fri Oct 13 08:49:22 2006
New Revision: 463716
URL: http://svn.apache.org/viewvc?view=rev&rev=463716
Log:
Getting closer...
Added:
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ContentHeaderProperties.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FieldTable.java (contents, props changed)
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/Frame.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/HeartbeatBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/MethodBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/transport/
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/transport/QpidTransportFactory.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/EncodingUtils.java (contents, props changed)
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/QpidWireFormat.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/QpidWireFormatFactory.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/
- copied from r462626, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/AccessRequestBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/AccessRequestBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/AccessRequestOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/AccessRequestOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicAckBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicAckBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicCancelBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicCancelBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicCancelOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicCancelOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicConsumeBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicConsumeOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicConsumeOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicDeliverBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicDeliverBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetEmptyBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetEmptyBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicGetOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicGetOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicPublishBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicPublishBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicQosBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicQosOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicQosOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicRecoverBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRecoverBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicRejectBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicRejectBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/BasicReturnBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/BasicReturnBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelAlertBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelAlertBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelCloseBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelCloseOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelCloseOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelFlowBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelFlowOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelFlowOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelOpenBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ChannelOpenOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ChannelOpenOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionCloseBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionCloseOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionCloseOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionOpenBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionOpenOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionOpenOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionRedirectBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionRedirectBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionSecureBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionSecureOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionSecureOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionStartBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionStartOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionStartOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionTuneBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ConnectionTuneOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ConnectionTuneOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxSelectBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxSelectOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxSelectOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxStartBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/DtxStartOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/DtxStartOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeclareBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeclareOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeclareOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeleteBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/ExchangeDeleteOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/ExchangeDeleteOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileAckBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileAckBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileCancelBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileCancelOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileCancelOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileConsumeBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileConsumeOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileConsumeOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileDeliverBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileDeliverBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileOpenBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileOpenOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileOpenOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FilePublishBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FilePublishBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileQosBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileQosOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileQosOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileRejectBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileRejectBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileReturnBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileReturnBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/FileStageBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/FileStageBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/MainRegistry.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/MainRegistry.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/MethodBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueBindBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueBindOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueBindOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeclareBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeclareOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeclareOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeleteBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueueDeleteOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueueDeleteOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueuePurgeBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/QueuePurgeOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/QueuePurgeOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamCancelBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamCancelOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamCancelOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamConsumeBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamConsumeOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamConsumeOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamDeliverBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamDeliverBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamPublishBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamPublishBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamQosBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamQosOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamQosOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/StreamReturnBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/StreamReturnBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestContentBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestContentOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestContentOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestIntegerBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestIntegerOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestIntegerOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestStringBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestStringOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestStringOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestTableBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TestTableOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TestTableOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TunnelRequestBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TunnelRequestBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxCommitBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxCommitOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxCommitOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxRollbackBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxRollbackOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxRollbackOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxSelectBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/wireformat/v8_0/TxSelectOkBodyMarshaller.java
- copied, changed from r462625, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/TxSelectOkBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/resources/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/DISCLAIMER.txt
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/LICENSE.txt (with props)
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/qpid
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/
incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/qpid
Removed:
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQFrame.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/AMQMethodBodyMarshaller.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/EncodingUtils.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/FieldTable.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/marshaller/v8_0/
Modified:
incubator/activemq/sandbox/qpid/build.xml
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionStartOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionTuneOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxSelectOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/DtxStartOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeclareOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ExchangeDeleteOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileAckBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileCancelOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileConsumeOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileDeliverBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileOpenOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FilePublishBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileQosOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileRejectBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileReturnBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/FileStageBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueBindOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeclareOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueueDeleteOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/QueuePurgeOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamCancelOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamConsumeOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamDeliverBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamPublishBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamQosOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/StreamReturnBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestContentOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestIntegerOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestStringOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TestTableOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TunnelRequestBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxCommitOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxRollbackOkBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectBody.java
incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/TxSelectOkBody.java
incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl
incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl
Modified: incubator/activemq/sandbox/qpid/build.xml
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/build.xml?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/build.xml (original)
+++ incubator/activemq/sandbox/qpid/build.xml Fri Oct 13 08:49:22 2006
@@ -59,8 +59,8 @@
<arg value="registry_name=MainRegistry"/>
</saxon>
- <mkdir dir="${target.src.dir}/org/apache/activemq/qpid/marshaller/v${@{ver}.amqp(major)}_${@{ver}.amqp(minor)}"/>
- <saxon out="${target.src.dir}/org/apache/activemq/qpid/marshaller/v${@{ver}.amqp(major)}_${@{ver}.amqp(minor)}/results.out"
+ <mkdir dir="${target.src.dir}/org/apache/activemq/qpid/wireformat/v${@{ver}.amqp(major)}_${@{ver}.amqp(minor)}"/>
+ <saxon out="${target.src.dir}/org/apache/activemq/qpid/wireformat/v${@{ver}.amqp(major)}_${@{ver}.amqp(minor)}/results.out"
src="${basedir}/specs/amqp-@{ver}.xml"
xsl="stylesheets/marshaller.xsl">
<arg value="major=${@{ver}.amqp(major)}"/>
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class AccessRequestBody extends AMQMethodBody
+public class AccessRequestBody extends MethodBody
{
+
+ public static final int CLASS_ID = 30;
+ public static final int METHOD_ID = 10;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String realm;
public boolean exclusive;
public boolean passive;
@@ -45,20 +59,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
- {
- AccessRequestBody body = new AccessRequestBody();
- body.realm = realm;
- body.exclusive = exclusive;
- body.passive = passive;
- body.active = active;
- body.write = write;
- body.read = read;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/AccessRequestOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class AccessRequestOkBody extends AMQMethodBody
+public class AccessRequestOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 30;
+ public static final int METHOD_ID = 11;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int ticket;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int ticket)
- {
- AccessRequestOkBody body = new AccessRequestOkBody();
- body.ticket = ticket;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicAckBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicAckBody extends AMQMethodBody
+public class BasicAckBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 80;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public long deliveryTag;
public boolean multiple;
@@ -37,16 +51,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean multiple)
- {
- BasicAckBody body = new BasicAckBody();
- body.deliveryTag = deliveryTag;
- body.multiple = multiple;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicCancelBody extends AMQMethodBody
+public class BasicCancelBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 30;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String consumerTag;
public boolean nowait;
@@ -37,16 +51,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String consumerTag, boolean nowait)
- {
- BasicCancelBody body = new BasicCancelBody();
- body.consumerTag = consumerTag;
- body.nowait = nowait;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicCancelOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicCancelOkBody extends AMQMethodBody
+public class BasicCancelOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 31;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String consumerTag;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String consumerTag)
- {
- BasicCancelOkBody body = new BasicCancelOkBody();
- body.consumerTag = consumerTag;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicConsumeBody extends AMQMethodBody
+public class BasicConsumeBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 20;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int ticket;
public String queue;
public String consumerTag;
@@ -47,21 +61,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, String consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait)
- {
- BasicConsumeBody body = new BasicConsumeBody();
- body.ticket = ticket;
- body.queue = queue;
- body.consumerTag = consumerTag;
- body.noLocal = noLocal;
- body.noAck = noAck;
- body.exclusive = exclusive;
- body.nowait = nowait;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicConsumeOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicConsumeOkBody extends AMQMethodBody
+public class BasicConsumeOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 21;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String consumerTag;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String consumerTag)
- {
- BasicConsumeOkBody body = new BasicConsumeOkBody();
- body.consumerTag = consumerTag;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicDeliverBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicDeliverBody extends AMQMethodBody
+public class BasicDeliverBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 60;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String consumerTag;
public long deliveryTag;
public boolean redelivered;
@@ -43,19 +57,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String consumerTag, long deliveryTag, boolean redelivered, String exchange, String routingKey)
- {
- BasicDeliverBody body = new BasicDeliverBody();
- body.consumerTag = consumerTag;
- body.deliveryTag = deliveryTag;
- body.redelivered = redelivered;
- body.exchange = exchange;
- body.routingKey = routingKey;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicGetBody extends AMQMethodBody
+public class BasicGetBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 70;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int ticket;
public String queue;
public boolean noAck;
@@ -39,17 +53,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int ticket, String queue, boolean noAck)
- {
- BasicGetBody body = new BasicGetBody();
- body.ticket = ticket;
- body.queue = queue;
- body.noAck = noAck;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetEmptyBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicGetEmptyBody extends AMQMethodBody
+public class BasicGetEmptyBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 72;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String clusterId;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String clusterId)
- {
- BasicGetEmptyBody body = new BasicGetEmptyBody();
- body.clusterId = clusterId;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicGetOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicGetOkBody extends AMQMethodBody
+public class BasicGetOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 71;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public long deliveryTag;
public boolean redelivered;
public String exchange;
@@ -43,19 +57,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean redelivered, String exchange, String routingKey, long messageCount)
- {
- BasicGetOkBody body = new BasicGetOkBody();
- body.deliveryTag = deliveryTag;
- body.redelivered = redelivered;
- body.exchange = exchange;
- body.routingKey = routingKey;
- body.messageCount = messageCount;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicPublishBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicPublishBody extends AMQMethodBody
+public class BasicPublishBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 40;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int ticket;
public String exchange;
public String routingKey;
@@ -43,19 +57,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int ticket, String exchange, String routingKey, boolean mandatory, boolean immediate)
- {
- BasicPublishBody body = new BasicPublishBody();
- body.ticket = ticket;
- body.exchange = exchange;
- body.routingKey = routingKey;
- body.mandatory = mandatory;
- body.immediate = immediate;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicQosBody extends AMQMethodBody
+public class BasicQosBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 10;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public long prefetchSize;
public int prefetchCount;
public boolean global;
@@ -39,17 +53,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, long prefetchSize, int prefetchCount, boolean global)
- {
- BasicQosBody body = new BasicQosBody();
- body.prefetchSize = prefetchSize;
- body.prefetchCount = prefetchCount;
- body.global = global;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicQosOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicQosOkBody extends AMQMethodBody
+public class BasicQosOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 11;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String toString()
@@ -33,14 +47,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId)
- {
- BasicQosOkBody body = new BasicQosOkBody();
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRecoverBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicRecoverBody extends AMQMethodBody
+public class BasicRecoverBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 100;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public boolean requeue;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, boolean requeue)
- {
- BasicRecoverBody body = new BasicRecoverBody();
- body.requeue = requeue;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicRejectBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicRejectBody extends AMQMethodBody
+public class BasicRejectBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 90;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public long deliveryTag;
public boolean requeue;
@@ -37,16 +51,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, long deliveryTag, boolean requeue)
- {
- BasicRejectBody body = new BasicRejectBody();
- body.deliveryTag = deliveryTag;
- body.requeue = requeue;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/BasicReturnBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class BasicReturnBody extends AMQMethodBody
+public class BasicReturnBody extends MethodBody
{
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 50;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int replyCode;
public String replyText;
public String exchange;
@@ -41,18 +55,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, String exchange, String routingKey)
- {
- BasicReturnBody body = new BasicReturnBody();
- body.replyCode = replyCode;
- body.replyText = replyText;
- body.exchange = exchange;
- body.routingKey = routingKey;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelAlertBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelAlertBody extends AMQMethodBody
+public class ChannelAlertBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 30;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int replyCode;
public String replyText;
public FieldTable details;
@@ -39,17 +53,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, FieldTable details)
- {
- ChannelAlertBody body = new ChannelAlertBody();
- body.replyCode = replyCode;
- body.replyText = replyText;
- body.details = details;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelCloseBody extends AMQMethodBody
+public class ChannelCloseBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 40;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int replyCode;
public String replyText;
public int classId;
@@ -41,18 +55,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId)
- {
- ChannelCloseBody body = new ChannelCloseBody();
- body.replyCode = replyCode;
- body.replyText = replyText;
- body.classId = classId;
- body.methodId = methodId;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelCloseOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelCloseOkBody extends AMQMethodBody
+public class ChannelCloseOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 41;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String toString()
@@ -33,14 +47,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId)
- {
- ChannelCloseOkBody body = new ChannelCloseOkBody();
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelFlowBody extends AMQMethodBody
+public class ChannelFlowBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 20;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public boolean active;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, boolean active)
- {
- ChannelFlowBody body = new ChannelFlowBody();
- body.active = active;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelFlowOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelFlowOkBody extends AMQMethodBody
+public class ChannelFlowOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 21;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public boolean active;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, boolean active)
- {
- ChannelFlowOkBody body = new ChannelFlowOkBody();
- body.active = active;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelOpenBody extends AMQMethodBody
+public class ChannelOpenBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 10;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String outOfBand;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String outOfBand)
- {
- ChannelOpenBody body = new ChannelOpenBody();
- body.outOfBand = outOfBand;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ChannelOpenOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ChannelOpenOkBody extends AMQMethodBody
+public class ChannelOpenOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 20;
+ public static final int METHOD_ID = 11;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String toString()
@@ -33,14 +47,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId)
- {
- ChannelOpenOkBody body = new ChannelOpenOkBody();
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionCloseBody extends AMQMethodBody
+public class ConnectionCloseBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 60;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public int replyCode;
public String replyText;
public int classId;
@@ -41,18 +55,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, int replyCode, String replyText, int classId, int methodId)
- {
- ConnectionCloseBody body = new ConnectionCloseBody();
- body.replyCode = replyCode;
- body.replyText = replyText;
- body.classId = classId;
- body.methodId = methodId;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionCloseOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionCloseOkBody extends AMQMethodBody
+public class ConnectionCloseOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 61;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String toString()
@@ -33,14 +47,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId)
- {
- ConnectionCloseOkBody body = new ConnectionCloseOkBody();
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionOpenBody extends AMQMethodBody
+public class ConnectionOpenBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 40;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String virtualHost;
public String capabilities;
public boolean insist;
@@ -39,17 +53,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String virtualHost, String capabilities, boolean insist)
- {
- ConnectionOpenBody body = new ConnectionOpenBody();
- body.virtualHost = virtualHost;
- body.capabilities = capabilities;
- body.insist = insist;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionOpenOkBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionOpenOkBody extends AMQMethodBody
+public class ConnectionOpenOkBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 41;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String knownHosts;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String knownHosts)
- {
- ConnectionOpenOkBody body = new ConnectionOpenOkBody();
- body.knownHosts = knownHosts;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionRedirectBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionRedirectBody extends AMQMethodBody
+public class ConnectionRedirectBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 50;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public String host;
public String knownHosts;
@@ -37,16 +51,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, String host, String knownHosts)
- {
- ConnectionRedirectBody body = new ConnectionRedirectBody();
- body.host = host;
- body.knownHosts = knownHosts;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java?view=diff&rev=463716&r1=463715&r2=463716
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/qpid/command/ConnectionSecureBody.java Fri Oct 13 08:49:22 2006
@@ -23,8 +23,22 @@
/**
* This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
*/
-public class ConnectionSecureBody extends AMQMethodBody
+public class ConnectionSecureBody extends MethodBody
{
+
+ public static final int CLASS_ID = 10;
+ public static final int METHOD_ID = 20;
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
public byte[] challenge;
@@ -35,15 +49,5 @@
return buf.toString();
}
-
- public static AMQFrame createAMQFrame(int channelId, byte[] challenge)
- {
- ConnectionSecureBody body = new ConnectionSecureBody();
- body.challenge = challenge;
-
- AMQFrame frame = new AMQFrame();
- frame.channel = channelId;
- frame.bodyFrame = body;
- return frame;
- }
+
}