Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 58934 invoked from network); 11 Jan 2009 20:24:17 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 11 Jan 2009 20:24:17 -0000 Received: (qmail 86715 invoked by uid 500); 11 Jan 2009 20:24:16 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 86683 invoked by uid 500); 11 Jan 2009 20:24:16 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 86645 invoked by uid 99); 11 Jan 2009 20:24:16 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 11 Jan 2009 12:24:16 -0800 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 11 Jan 2009 20:24:05 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 5CAA92388C10; Sun, 11 Jan 2009 12:22:59 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r733509 [23/33] - in /activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire: ./ marshal/ marshal/v1/ marshal/v2/ marshal/v3/ utils/ Date: Sun, 11 Jan 2009 20:22:43 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090111202259.5CAA92388C10@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h Sun Jan 11 12:22:34 2009 @@ -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. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_WIREFORMATINFOMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_WIREFORMATINFOMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for WireFormatInfoMarshaller + * + * 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 AMQCPP_API WireFormatInfoMarshaller : public BaseDataStreamMarshaller { + public: + + WireFormatInfoMarshaller() {} + virtual ~WireFormatInfoMarshaller() {} + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual commands::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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_WIREFORMATINFOMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,156 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v2; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* XATransactionIdMarshaller::createObject() const { + return new XATransactionId(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char XATransactionIdMarshaller::getDataStructureType() const { + return XATransactionId::ID_XATRANSACTIONID; +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + XATransactionId* info = + dynamic_cast( dataStructure ); + info->setFormatId( dataIn->readInt() ); + info->setGlobalTransactionId( tightUnmarshalByteArray( dataIn, bs ) ); + info->setBranchQualifier( tightUnmarshalByteArray( dataIn, bs ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int XATransactionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + XATransactionId* info = + dynamic_cast( dataStructure ); + + int rc = TransactionIdMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + bs->writeBoolean( info->getGlobalTransactionId().size() != 0 ); + rc += info->getGlobalTransactionId().size() == 0 ? 0 : (int)info->getGlobalTransactionId().size() + 4; + bs->writeBoolean( info->getBranchQualifier().size() != 0 ); + rc += info->getBranchQualifier().size() == 0 ? 0 : (int)info->getBranchQualifier().size() + 4; + + return rc + 4; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + XATransactionId* info = + dynamic_cast( dataStructure ); + dataOut->writeInt( info->getFormatId() ); + if( bs->readBoolean() ) { + dataOut->writeInt( (int)info->getGlobalTransactionId().size() ); + dataOut->write( (const unsigned char*)(&info->getGlobalTransactionId()[0]), 0, (int)info->getGlobalTransactionId().size() ); + } + if( bs->readBoolean() ) { + dataOut->writeInt( (int)info->getBranchQualifier().size() ); + dataOut->write( (const unsigned char*)(&info->getBranchQualifier()[0]), 0, (int)info->getBranchQualifier().size() ); + } + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + XATransactionId* info = + dynamic_cast( dataStructure ); + info->setFormatId( dataIn->readInt() ); + info->setGlobalTransactionId( looseUnmarshalByteArray( dataIn ) ); + info->setBranchQualifier( looseUnmarshalByteArray( dataIn ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + XATransactionId* info = + dynamic_cast( dataStructure ); + TransactionIdMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->writeInt( info->getFormatId() ); + dataOut->write( info->getGlobalTransactionId().size() != 0 ); + if( info->getGlobalTransactionId().size() != 0 ) { + dataOut->writeInt( (int)info->getGlobalTransactionId().size() ); + dataOut->write( (const unsigned char*)(&info->getGlobalTransactionId()[0]), 0, (int)info->getGlobalTransactionId().size() ); + } + dataOut->write( info->getBranchQualifier().size() != 0 ); + if( info->getBranchQualifier().size() != 0 ) { + dataOut->writeInt( (int)info->getBranchQualifier().size() ); + dataOut->write( (const unsigned char*)(&info->getBranchQualifier()[0]), 0, (int)info->getBranchQualifier().size() ); + } + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h Sun Jan 11 12:22:34 2009 @@ -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. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_XATRANSACTIONIDMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_XATRANSACTIONIDMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for XATransactionIdMarshaller + * + * 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 AMQCPP_API XATransactionIdMarshaller : public TransactionIdMarshaller { + public: + + XATransactionIdMarshaller() {} + virtual ~XATransactionIdMarshaller() {} + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual commands::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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V2_XATRANSACTIONIDMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/srcmakefile.mk URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/srcmakefile.mk?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/srcmakefile.mk (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v2/srcmakefile.mk Sun Jan 11 12:22:34 2009 @@ -0,0 +1,144 @@ +# --------------------------------------------------------------------------- +# 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. +# --------------------------------------------------------------------------- + +cc_sources += \ + activemq/wireformat/openwire/marshal/v2/ActiveMQBlobMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQBytesMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQDestinationMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQMapMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQObjectMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQQueueMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQStreamMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempQueueMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempTopicMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTextMessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTopicMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/BaseCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/BrokerIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/BrokerInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConnectionControlMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConnectionErrorMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConnectionIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConnectionInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConsumerControlMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConsumerIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ConsumerInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ControlCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/DataArrayResponseMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/DataResponseMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/DestinationInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/DiscoveryEventMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ExceptionResponseMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/FlushCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/IntegerResponseMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/JournalQueueAckMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/JournalTopicAckMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/JournalTraceMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/JournalTransactionMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/KeepAliveInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/LastPartialCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/LocalTransactionIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MarshallerFactory.cpp \ + activemq/wireformat/openwire/marshal/v2/MessageAckMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MessageDispatchMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MessageDispatchNotificationMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MessageIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MessageMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/MessagePullMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/NetworkBridgeFilterMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/PartialCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ProducerAckMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ProducerIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ProducerInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/RemoveInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/RemoveSubscriptionInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ReplayCommandMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ResponseMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/SessionIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/SessionInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/ShutdownInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/SubscriptionInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/TransactionIdMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/TransactionInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.cpp \ + activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.cpp + +h_sources += \ + activemq/wireformat/openwire/marshal/v2/ActiveMQBlobMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQBytesMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQDestinationMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQMapMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQObjectMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQQueueMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQStreamMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempQueueMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTempTopicMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTextMessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ActiveMQTopicMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/BaseCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/BrokerIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/BrokerInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConnectionControlMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConnectionErrorMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConnectionIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConnectionInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConsumerControlMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConsumerIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ConsumerInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ControlCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/DataArrayResponseMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/DataResponseMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/DestinationInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/DiscoveryEventMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ExceptionResponseMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/FlushCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/IntegerResponseMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/JournalQueueAckMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/JournalTopicAckMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/JournalTraceMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/JournalTransactionMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/KeepAliveInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/LastPartialCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/LocalTransactionIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MarshallerFactory.h \ + activemq/wireformat/openwire/marshal/v2/MessageAckMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MessageDispatchMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MessageDispatchNotificationMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MessageIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MessageMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/MessagePullMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/NetworkBridgeFilterMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/PartialCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ProducerAckMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ProducerIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ProducerInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/RemoveInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/RemoveSubscriptionInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ReplayCommandMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ResponseMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/SessionIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/SessionInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/ShutdownInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/SubscriptionInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/TransactionIdMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/TransactionInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/WireFormatInfoMarshaller.h \ + activemq/wireformat/openwire/marshal/v2/XATransactionIdMarshaller.h Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,141 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v3; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQBlobMessageMarshaller::createObject() const { + return new ActiveMQBlobMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQBlobMessageMarshaller::getDataStructureType() const { + return ActiveMQBlobMessage::ID_ACTIVEMQBLOBMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBlobMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQBlobMessage* info = + dynamic_cast( dataStructure ); + info->setRemoteBlobUrl( tightUnmarshalString( dataIn, bs ) ); + info->setMimeType( tightUnmarshalString( dataIn, bs ) ); + info->setDeletedByBroker( bs->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQBlobMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQBlobMessage* info = + dynamic_cast( dataStructure ); + + int rc = ActiveMQMessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getRemoteBlobUrl(), bs ); + rc += tightMarshalString1( info->getMimeType(), bs ); + bs->writeBoolean( info->isDeletedByBroker() ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBlobMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQBlobMessage* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getRemoteBlobUrl(), dataOut, bs ); + tightMarshalString2( info->getMimeType(), dataOut, bs ); + bs->readBoolean(); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBlobMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQBlobMessage* info = + dynamic_cast( dataStructure ); + info->setRemoteBlobUrl( looseUnmarshalString( dataIn ) ); + info->setMimeType( looseUnmarshalString( dataIn ) ); + info->setDeletedByBroker( dataIn->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBlobMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ActiveMQBlobMessage* info = + dynamic_cast( dataStructure ); + ActiveMQMessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getRemoteBlobUrl(), dataOut ); + looseMarshalString( info->getMimeType(), dataOut ); + dataOut->writeBoolean( info->isDeletedByBroker() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h Sun Jan 11 12:22:34 2009 @@ -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. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBLOBMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBLOBMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v3{ + + /** + * Marshalling code for Open Wire Format for ActiveMQBlobMessageMarshaller + * + * 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 AMQCPP_API ActiveMQBlobMessageMarshaller : public ActiveMQMessageMarshaller { + public: + + ActiveMQBlobMessageMarshaller() {} + virtual ~ActiveMQBlobMessageMarshaller() {} + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual commands::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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBLOBMESSAGEMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBlobMessageMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,136 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v3; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQBytesMessageMarshaller::createObject() const { + return new ActiveMQBytesMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQBytesMessageMarshaller::getDataStructureType() const { + return ActiveMQBytesMessage::ID_ACTIVEMQBYTESMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQBytesMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h Sun Jan 11 12:22:34 2009 @@ -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. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v3{ + + /** + * Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller + * + * 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 AMQCPP_API ActiveMQBytesMessageMarshaller : public MessageMarshaller { + public: + + ActiveMQBytesMessageMarshaller() {} + virtual ~ActiveMQBytesMessageMarshaller() {} + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual commands::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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQBYTESMESSAGEMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQBytesMessageMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,121 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v3; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + info->setPhysicalName( tightUnmarshalString( dataIn, bs ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQDestinationMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getPhysicalName(), bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getPhysicalName(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + info->setPhysicalName( looseUnmarshalString( dataIn ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getPhysicalName(), dataOut ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h Sun Jan 11 12:22:34 2009 @@ -0,0 +1,115 @@ +/* + * 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_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQDESTINATIONMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQDESTINATIONMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v3{ + + /** + * Marshalling code for Open Wire Format for ActiveMQDestinationMarshaller + * + * 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 AMQCPP_API ActiveMQDestinationMarshaller : public BaseDataStreamMarshaller { + public: + + ActiveMQDestinationMarshaller() {} + virtual ~ActiveMQDestinationMarshaller() {} + + /** + * 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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQDESTINATIONMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQDestinationMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,136 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v3; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQMapMessageMarshaller::createObject() const { + return new ActiveMQMapMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQMapMessageMarshaller::getDataStructureType() const { + return ActiveMQMapMessage::ID_ACTIVEMQMAPMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQMapMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h Sun Jan 11 12:22:34 2009 @@ -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. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQMAPMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQMAPMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v3{ + + /** + * Marshalling code for Open Wire Format for ActiveMQMapMessageMarshaller + * + * 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 AMQCPP_API ActiveMQMapMessageMarshaller : public MessageMarshaller { + public: + + ActiveMQMapMessageMarshaller() {} + virtual ~ActiveMQMapMessageMarshaller() {} + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual commands::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, + decaf::io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( decaf::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, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( decaf::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, + decaf::io::DataInputStream* dataIn ) throw( decaf::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, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V3_ACTIVEMQMAPMESSAGEMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMapMessageMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v3/ActiveMQMessageMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,136 @@ +/* + * 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 +#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::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v3; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQMessageMarshaller::createObject() const { + return new ActiveMQMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQMessageMarshaller::getDataStructureType() const { + return ActiveMQMessage::ID_ACTIVEMQMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} +