Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 91150 invoked from network); 18 Oct 2007 13:12:40 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 18 Oct 2007 13:12:40 -0000 Received: (qmail 17642 invoked by uid 500); 18 Oct 2007 13:12:28 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 17585 invoked by uid 500); 18 Oct 2007 13:12:28 -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 17576 invoked by uid 99); 18 Oct 2007 13:12:28 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Oct 2007 06:12:28 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO eris.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Oct 2007 13:12:38 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id E859D1A9859; Thu, 18 Oct 2007 06:11:26 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r585955 [9/10] - /activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ Date: Thu, 18 Oct 2007 13:11:14 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20071018131126.E859D1A9859@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for SessionInfoMarshaller + * + * 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 SessionInfoMarshaller : public BaseCommandMarshaller + { + public: + + SessionInfoMarshaller() {} + virtual ~SessionInfoMarshaller() {} + + /** + * 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,112 @@ +/* + * 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ShutdownInfoMarshaller::createObject() const { + return new ShutdownInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ShutdownInfoMarshaller::getDataStructureType() const { + return ShutdownInfo::ID_SHUTDOWNINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ShutdownInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ShutdownInfoMarshaller + * + * 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 ShutdownInfoMarshaller : public BaseCommandMarshaller + { + public: + + ShutdownInfoMarshaller() {} + virtual ~ShutdownInfoMarshaller() {} + + /** + * 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,145 @@ +/* + * 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* SubscriptionInfoMarshaller::createObject() const { + return new SubscriptionInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char SubscriptionInfoMarshaller::getDataStructureType() const { + return SubscriptionInfo::ID_SUBSCRIPTIONINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + SubscriptionInfo* info = + dynamic_cast( dataStructure ); + info->setClientId( tightUnmarshalString( dataIn, bs ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setSelector( tightUnmarshalString( dataIn, bs ) ); + info->setSubcriptionName( tightUnmarshalString( dataIn, bs ) ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int SubscriptionInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + SubscriptionInfo* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getClientId(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getDestination(), bs ); + rc += tightMarshalString1( info->getSelector(), bs ); + rc += tightMarshalString1( info->getSubcriptionName(), bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + SubscriptionInfo* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getClientId(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getDestination(), dataOut, bs ); + tightMarshalString2( info->getSelector(), dataOut, bs ); + tightMarshalString2( info->getSubcriptionName(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + SubscriptionInfo* info = + dynamic_cast( dataStructure ); + info->setClientId( looseUnmarshalString( dataIn ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setSelector( looseUnmarshalString( dataIn ) ); + info->setSubcriptionName( looseUnmarshalString( dataIn ) ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + SubscriptionInfo* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getClientId(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getDestination(), dataOut ); + looseMarshalString( info->getSelector(), dataOut ); + looseMarshalString( info->getSubcriptionName(), dataOut ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for SubscriptionInfoMarshaller + * + * 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 SubscriptionInfoMarshaller : public BaseDataStreamMarshaller + { + public: + + SubscriptionInfoMarshaller() {} + virtual ~SubscriptionInfoMarshaller() {} + + /** + * 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,102 @@ +/* + * 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +void TransactionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int TransactionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONIDMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONIDMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for TransactionIdMarshaller + * + * 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 TransactionIdMarshaller : public BaseDataStreamMarshaller + { + public: + + TransactionIdMarshaller() {} + virtual ~TransactionIdMarshaller() {} + + /** + * 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, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONIDMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -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 + +// +// 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* TransactionInfoMarshaller::createObject() const { + return new TransactionInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char TransactionInfoMarshaller::getDataStructureType() const { + return TransactionInfo::ID_TRANSACTIONINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + TransactionInfo* info = + dynamic_cast( dataStructure ); + info->setConnectionId( dynamic_cast< ConnectionId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setType( dataIn->readByte() ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int TransactionInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + TransactionInfo* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getConnectionId(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getTransactionId(), bs ); + + return rc + 1; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + TransactionInfo* info = + dynamic_cast( dataStructure ); + tightMarshalCachedObject2( wireFormat, info->getConnectionId(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getTransactionId(), dataOut, bs ); + dataOut->write( info->getType() ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + TransactionInfo* info = + dynamic_cast( dataStructure ); + info->setConnectionId( dynamic_cast< ConnectionId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setType( dataIn->readByte() ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + TransactionInfo* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalCachedObject( wireFormat, info->getConnectionId(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getTransactionId(), dataOut ); + dataOut->write( info->getType() ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for TransactionInfoMarshaller + * + * 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 TransactionInfoMarshaller : public BaseCommandMarshaller + { + public: + + TransactionInfoMarshaller() {} + virtual ~TransactionInfoMarshaller() {} + + /** + * 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,154 @@ +/* + * 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* WireFormatInfoMarshaller::createObject() const { + return new WireFormatInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char WireFormatInfoMarshaller::getDataStructureType() const { + return WireFormatInfo::ID_WIREFORMATINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void WireFormatInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + WireFormatInfo* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + info->setMagic( tightUnmarshalConstByteArray( dataIn, bs, 8 ) ); + info->setVersion( dataIn->readInt() ); + info->setMarshalledProperties( tightUnmarshalByteArray( dataIn, bs ) ); + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int WireFormatInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + WireFormatInfo* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + bs->writeBoolean( info->getMarshalledProperties().size() != 0 ); + rc += info->getMarshalledProperties().size() == 0 ? 0 : (int)info->getMarshalledProperties().size() + 4; + + return rc + 12; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void WireFormatInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + WireFormatInfo* info = + dynamic_cast( dataStructure ); + dataOut->write( (const unsigned char*)(&info->getMagic()[0]), 8 ); + dataOut->writeInt( info->getVersion() ); + if( bs->readBoolean() ) { + dataOut->writeInt( (int)info->getMarshalledProperties().size() ); + dataOut->write( (const unsigned char*)(&info->getMarshalledProperties()[0]), (int)info->getMarshalledProperties().size() ); + } + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void WireFormatInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + WireFormatInfo* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->setMagic( looseUnmarshalConstByteArray( dataIn, 8 ) ); + info->setVersion( dataIn->readInt() ); + info->setMarshalledProperties( looseUnmarshalByteArray( dataIn ) ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void WireFormatInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + WireFormatInfo* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->write( (const unsigned char*)(&info->getMagic()[0]), (int)8 ); + dataOut->writeInt( info->getVersion() ); + dataOut->write( info->getMarshalledProperties().size() != 0 ); + if( info->getMarshalledProperties().size() != 0 ) { + dataOut->writeInt( (int)info->getMarshalledProperties().size() ); + dataOut->write( (const unsigned char*)(&info->getMarshalledProperties()[0]), (int)info->getMarshalledProperties().size() ); + } + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_WIREFORMATINFOMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_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 + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * 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 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_WIREFORMATINFOMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,153 @@ +/* + * 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::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +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( 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( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int XATransactionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( 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( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( 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]), (int)info->getGlobalTransactionId().size() ); + } + if( bs->readBoolean() ) { + dataOut->writeInt( (int)info->getBranchQualifier().size() ); + dataOut->write( (const unsigned char*)(&info->getBranchQualifier()[0]), (int)info->getBranchQualifier().size() ); + } + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( 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( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void XATransactionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( 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]), (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]), (int)info->getBranchQualifier().size() ); + } + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.h Thu Oct 18 06:11:09 2007 @@ -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_CONNECTOR_OPENWIRE_MARSAHAL_V1_XATRANSACTIONIDMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_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 + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * 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 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, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( 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( 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, + utils::BooleanStream* bs ) throw( 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 ) throw( 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 ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_XATRANSACTIONIDMARSHALLER_H_*/ +