Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 83905 invoked from network); 2 Oct 2006 14:32:44 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 2 Oct 2006 14:32:44 -0000 Received: (qmail 72488 invoked by uid 500); 2 Oct 2006 14:32:44 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 72466 invoked by uid 500); 2 Oct 2006 14:32:44 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 72457 invoked by uid 99); 2 Oct 2006 14:32:44 -0000 Received: from idunn.apache.osuosl.org (HELO idunn.apache.osuosl.org) (140.211.166.84) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Oct 2006 07:32:44 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=5.0 tests=ALL_TRUSTED,NO_REAL_NAME Received: from [140.211.166.113] ([140.211.166.113:58880] helo=eris.apache.org) by idunn.apache.osuosl.org (ecelerity 2.1.1.8 r(12930)) with ESMTP id 7C/6B-16499-ED221254 for ; Mon, 02 Oct 2006 07:32:02 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 978F91A9872; Mon, 2 Oct 2006 07:30:38 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r452053 [14/17] - in /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/ main/activemq/connector/openwire/marshal/ main/activemq/connector/openwire/marshal/V2... Date: Mon, 02 Oct 2006 14:30:22 -0000 To: activemq-commits@geronimo.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20061002143038.978F91A9872@eris.apache.org> X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageDispatchNotificationMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageDispatchNotificationMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageDispatchNotificationMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageDispatchNotificationMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEDISPATCHNOTIFICATIONMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEDISPATCHNOTIFICATIONMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for MessageDispatchNotificationMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class MessageDispatchNotificationMarshaller : public BaseCommandMarshaller + { + public: + + MessageDispatchNotificationMarshaller() {}; + virtual ~MessageDispatchNotificationMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEDISPATCHNOTIFICATIONMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageDispatchNotificationMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* MessageIdMarshaller::createObject() const { + return new MessageId(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char MessageIdMarshaller::getDataStructureType() const { + return MessageId::ID_MESSAGEID; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + MessageId* info = + dynamic_cast( dataStructure ); + info->setProducerId( dynamic_cast< ProducerId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setProducerSequenceId( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setBrokerSequenceId( TightUnmarshalLong( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int MessageIdMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + MessageId* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + rc += tightMarshalLong1( wireFormat, info->getProducerSequenceId(), bs ); + rc += tightMarshalLong1( wireFormat, info->getBrokerSequenceId(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageIdMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + MessageId* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + tightMarshalLong2( wireFormat, info->getProducerSequenceId(), dataOut, bs ); + tightMarshalLong2( wireFormat, info->getBrokerSequenceId(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageIdMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + MessageId* info = + dynamic_cast( dataStructure ); + info->setProducerId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setProducerSequenceId( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setBrokerSequenceId( looseUnmarshalLong( wireFormat, dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageIdMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + MessageId* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + looseMarshalLong( wireFormat, info->getProducerSequenceId(), dataOut ); + looseMarshalLong( wireFormat, info->getBrokerSequenceId(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEIDMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEIDMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for MessageIdMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class MessageIdMarshaller : public BaseDataStreamMarshaller + { + public: + + MessageIdMarshaller() {}; + virtual ~MessageIdMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEIDMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageIdMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,341 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +void MessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + Message* info = + dynamic_cast( dataStructure ); + info->setProducerId( dynamic_cast< ProducerId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setOriginalDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setMessageId( dynamic_cast< MessageId* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setOriginalTransactionId( dynamic_cast< TransactionId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setGroupID( TightUnmarshalString( dataIn, bs ) ); + info->setGroupSequence( dataIn->readInt() ); + info->setCorrelationId( TightUnmarshalString( dataIn, bs ) ); + info->setPersistent( bs->readBoolean() ); + info->setExpiration( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setPriority( dataIn->readByte() ); + info->setReplyTo( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setTimestamp( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setType( TightUnmarshalString( dataIn, bs ) ); + info->setContent( tightUnmarshalByteArray( dataIn, bs ) ); + info->setMarshalledProperties( tightUnmarshalByteArray( dataIn, bs ) ); + info->setDataStructure( dynamic_cast< DataStructure* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setTargetConsumerId( dynamic_cast< ConsumerId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setCompressed( bs->readBoolean() ); + info->setRedeliveryCounter( dataIn->readInt() ); + + if( bs->readBoolean() ) { + short size = dataIn->readShort(); + BrokerId* value = new BrokerId[size]; + for( int i = 0; i < size; i++ ) { + value[i] = dynamic_cast< BrokerId* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + } + info->setBrokerPath( value ); + } + else { + info->setBrokerPath( NULL ); + } + info->setArrival( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setUserID( TightUnmarshalString( dataIn, bs ) ); + info->setRecievedByDFBridge( bs->readBoolean() ); +} + +/////////////////////////////////////////////////////////////////////////////// +int MessageMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + Message* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalDestination() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalTransactionId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + rc += tightMarshalString1( info->getGroupID(), bs ); + rc += tightMarshalString1( info->getCorrelationId(), bs ); + bs->writeBoolean( info->isPersistent() ); + rc += tightMarshalLong1( wireFormat, info->getExpiration(), bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getReplyTo() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + rc += tightMarshalLong1( wireFormat, info->getTimestamp(), bs ); + rc += tightMarshalString1( info->getType(), bs ); + bs->writeBoolean( info->getContent() != NULL ); + rc += info->getContent()() == NULL ? 0 : info->getContent().Length + 4; + bs->writeBoolean( info->getMarshalledProperties() != NULL ); + rc += info->getMarshalledProperties()() == NULL ? 0 : info->getMarshalledProperties().Length + 4; + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDataStructure() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTargetConsumerId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + bs->writeBoolean( info->isCompressed() ); + rc += tightMarshalObjectArray1( wireFormat, info->getBrokerPath(), bs ); + rc += tightMarshalLong1( wireFormat, info->getArrival(), bs ); + rc += tightMarshalString1( info->getUserID(), bs ); + bs->writeBoolean( info->isRecievedByDFBridge() ); + + return rc + 9; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + Message* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalDestination() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalTransactionId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + tightMarshalString2( info->getGroupID(), dataOut, bs ); + dataOut->write( info->getGroupSequence() ); + tightMarshalString2( info->getCorrelationId(), dataOut, bs ); + bs->readBoolean(); + tightMarshalLong2( wireFormat, info->getExpiration(), dataOut, bs ); + dataOut->write( info->getPriority() ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getReplyTo() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + tightMarshalLong2( wireFormat, info->getTimestamp(), dataOut, bs ); + tightMarshalString2( info->getType(), dataOut, bs ); + if( bs->readBoolean() ) { + dataOut->write( info->getContent().Length ); + dataOut->write( info->getContent() ); + } + if( bs->readBoolean() ) { + dataOut->write( info->getMarshalledProperties().Length ); + dataOut->write( info->getMarshalledProperties() ); + } + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDataStructure() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTargetConsumerId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + bs->readBoolean(); + dataOut->write( info->getRedeliveryCounter() ); + tightMarshalObjectArray2( wireFormat, info->getBrokerPath(), dataOut, bs ); + tightMarshalLong2( wireFormat, info->getArrival(), dataOut, bs ); + tightMarshalString2( info->getUserID(), dataOut, bs ); + bs->readBoolean(); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + Message* info = + dynamic_cast( dataStructure ); + info->setProducerId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setDestination( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setTransactionId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setOriginalDestination( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setMessageId( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setOriginalTransactionId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setGroupID( looseUnmarshalString( dataIn ) ); + info->setGroupSequence( dataIn->readInt() ); + info->setCorrelationId( looseUnmarshalString( dataIn ) ); + info->setPersistent( dataIn->readBoolean() ); + info->setExpiration( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setPriority( dataIn->readByte() ); + info->setReplyTo( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setTimestamp( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setType( looseUnmarshalString( dataIn ) ); + info->setContent( looseUnmarshalByteArray( dataIn ) ); + info->setMarshalledProperties( looseUnmarshalByteArray( dataIn ) ); + info->setDataStructure( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setTargetConsumerId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setCompressed( dataIn->readBoolean() ); + info->setRedeliveryCounter( dataIn->readInt() ); + + if( dataIn->readBoolean() ) { + short size = dataIn->readShort(); + BrokerId* value = new BrokerId[size]; + for( int i = 0; i < size; i++ ) { + value[i] = dynamic_cast( + looseUnmarshalNestedObject( wireFormat,dataIn ) ); + } + info->setBrokerPath( value ); + } + else { + info->setBrokerPath( NULL ); + } + info->setArrival( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setUserID( looseUnmarshalString( dataIn ) ); + info->setRecievedByDFBridge( dataIn->readBoolean() ); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + Message* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getProducerId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalDestination() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getOriginalTransactionId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + looseMarshalString( info->getGroupID(), dataOut ); + dataOut->write( info->getGroupSequence() ); + looseMarshalString( info->getCorrelationId(), dataOut ); + dataOut->write( info->isPersistent() ); + looseMarshalLong( wireFormat, info->getExpiration(), dataOut ); + dataOut->write( info->getPriority() ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getReplyTo() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + looseMarshalLong( wireFormat, info->getTimestamp(), dataOut ); + looseMarshalString( info->getType(), dataOut ); + dataOut->write( info->getContent() != NULL ); + if( info->getContent() != NULL ) { + dataOut->write( info->getContent().Length ); + dataOut->write( info->getContent() ); + } + dataOut->write( info->getMarshalledProperties() != NULL ); + if( info->getMarshalledProperties() != NULL ) { + dataOut->write( info->getMarshalledProperties().Length ); + dataOut->write( info->getMarshalledProperties() ); + } + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDataStructure() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTargetConsumerId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + dataOut->write( info->isCompressed() ); + dataOut->write( info->getRedeliveryCounter() ); + looseMarshalObjectArray( wireFormat, info->getBrokerPath(), dataOut ); + looseMarshalLong( wireFormat, info->getArrival(), dataOut ); + looseMarshalString( info->getUserID(), dataOut ); + dataOut->write( info->isRecievedByDFBridge() ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for MessageMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class MessageMarshaller : public BaseCommandMarshaller + { + public: + + MessageMarshaller() {}; + virtual ~MessageMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessageMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* MessagePullMarshaller::createObject() const { + return new MessagePull(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char MessagePullMarshaller::getDataStructureType() const { + return MessagePull::ID_MESSAGEPULL; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessagePullMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + MessagePull* info = + dynamic_cast( dataStructure ); + info->setConsumerId( dynamic_cast< ConsumerId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); + info->setTimeout( TightUnmarshalLong( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int MessagePullMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + MessagePull* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getConsumerId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + rc += tightMarshalLong1( wireFormat, info->getTimeout(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessagePullMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + MessagePull* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getConsumerId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); + tightMarshalLong2( wireFormat, info->getTimeout(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessagePullMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + MessagePull* info = + dynamic_cast( dataStructure ); + info->setConsumerId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setDestination( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setTimeout( looseUnmarshalLong( wireFormat, dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void MessagePullMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + MessagePull* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getConsumerId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); + looseMarshalLong( wireFormat, info->getTimeout(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEPULLMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEPULLMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for MessagePullMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class MessagePullMarshaller : public BaseCommandMarshaller + { + public: + + MessagePullMarshaller() {}; + virtual ~MessagePullMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_MESSAGEPULLMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/MessagePullMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* NetworkBridgeFilterMarshaller::createObject() const { + return new NetworkBridgeFilter(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char NetworkBridgeFilterMarshaller::getDataStructureType() const { + return NetworkBridgeFilter::ID_NETWORKBRIDGEFILTER; +} + +/////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilterMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + NetworkBridgeFilter* info = + dynamic_cast( dataStructure ); + info->setNetworkTTL( dataIn->readInt() ); + info->setNetworkBrokerId( dynamic_cast< BrokerId* >( + tightUnmarsalCachedObject( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int NetworkBridgeFilterMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + NetworkBridgeFilter* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getNetworkBrokerId() ); + + rc += tightMarshalCachedObject1( wireFormat, data, bs ); + + return rc + 4; +} + +/////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilterMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + NetworkBridgeFilter* info = + dynamic_cast( dataStructure ); + dataOut->write( info->getNetworkTTL() ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getNetworkBrokerId() ); + + tightMarshalCachedObject2( wireFormat, data, dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilterMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + NetworkBridgeFilter* info = + dynamic_cast( dataStructure ); + info->setNetworkTTL( dataIn->readInt() ); + info->setNetworkBrokerId( dynamic_cast( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilterMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + NetworkBridgeFilter* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->write( info->getNetworkTTL() ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getNetworkBrokerId() ); + + looseMarshalCachedObject( wireFormat, data, dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_NETWORKBRIDGEFILTERMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_NETWORKBRIDGEFILTERMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for NetworkBridgeFilterMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller + { + public: + + NetworkBridgeFilterMarshaller() {}; + virtual ~NetworkBridgeFilterMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_NETWORKBRIDGEFILTERMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/NetworkBridgeFilterMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* PartialCommandMarshaller::createObject() const { + return new PartialCommand(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char PartialCommandMarshaller::getDataStructureType() const { + return PartialCommand::ID_PARTIALCOMMAND; +} + +/////////////////////////////////////////////////////////////////////////////// +void PartialCommandMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + PartialCommand* info = + dynamic_cast( dataStructure ); + info->setCommandId( dataIn->readInt() ); + info->setData( tightUnmarshalByteArray( dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int PartialCommandMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + PartialCommand* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + bs->writeBoolean( info->getData() != NULL ); + rc += info->getData()() == NULL ? 0 : info->getData().Length + 4; + + return rc + 4; +} + +/////////////////////////////////////////////////////////////////////////////// +void PartialCommandMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + PartialCommand* info = + dynamic_cast( dataStructure ); + dataOut->write( info->getCommandId() ); + if( bs->readBoolean() ) { + dataOut->write( info->getData().Length ); + dataOut->write( info->getData() ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void PartialCommandMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + PartialCommand* info = + dynamic_cast( dataStructure ); + info->setCommandId( dataIn->readInt() ); + info->setData( looseUnmarshalByteArray( dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void PartialCommandMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + PartialCommand* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->write( info->getCommandId() ); + dataOut->write( info->getData() != NULL ); + if( info->getData() != NULL ) { + dataOut->write( info->getData().Length ); + dataOut->write( info->getData() ); + } +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_PARTIALCOMMANDMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_PARTIALCOMMANDMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for PartialCommandMarshaller + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class PartialCommandMarshaller : public BaseDataStreamMarshaller + { + public: + + PartialCommandMarshaller() {}; + virtual ~PartialCommandMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_PARTIALCOMMANDMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/PartialCommandMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ProducerIdMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ProducerIdMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ProducerIdMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ProducerIdMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ProducerIdMarshaller::createObject() const { + return new ProducerId(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ProducerIdMarshaller::getDataStructureType() const { + return ProducerId::ID_PRODUCERID; +} + +/////////////////////////////////////////////////////////////////////////////// +void ProducerIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ProducerId* info = + dynamic_cast( dataStructure ); + info->setConnectionId( TightUnmarshalString( dataIn, bs ) ); + info->setValue( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setSessionId( TightUnmarshalLong( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int ProducerIdMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + ProducerId* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getConnectionId(), bs ); + rc += tightMarshalLong1( wireFormat, info->getValue(), bs ); + rc += tightMarshalLong1( wireFormat, info->getSessionId(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void ProducerIdMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ProducerId* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getConnectionId(), dataOut, bs ); + tightMarshalLong2( wireFormat, info->getValue(), dataOut, bs ); + tightMarshalLong2( wireFormat, info->getSessionId(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void ProducerIdMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ProducerId* info = + dynamic_cast( dataStructure ); + info->setConnectionId( looseUnmarshalString( dataIn ) ); + info->setValue( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setSessionId( looseUnmarshalLong( wireFormat, dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void ProducerIdMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + ProducerId* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getConnectionId(), dataOut ); + looseMarshalLong( wireFormat, info->getValue(), dataOut ); + looseMarshalLong( wireFormat, info->getSessionId(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ProducerIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native