Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 58280 invoked from network); 11 Jan 2009 20:23:44 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 11 Jan 2009 20:23:44 -0000 Received: (qmail 84843 invoked by uid 500); 11 Jan 2009 20:23:44 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 84819 invoked by uid 500); 11 Jan 2009 20:23:44 -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 84810 invoked by uid 99); 11 Jan 2009 20:23:44 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 11 Jan 2009 12:23:44 -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:23:42 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id AD4682388B68; Sun, 11 Jan 2009 12:22:58 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r733509 [9/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: <20090111202258.AD4682388B68@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.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_V1_JOURNALTRANSACTIONMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_JOURNALTRANSACTIONMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for JournalTransactionMarshaller + * + * 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 JournalTransactionMarshaller : public BaseDataStreamMarshaller { + public: + + JournalTransactionMarshaller() {} + virtual ~JournalTransactionMarshaller() {} + + /** + * 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_V1_JOURNALTRANSACTIONMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/JournalTransactionMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp 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. + */ + +#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::v1; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* KeepAliveInfoMarshaller::createObject() const { + return new KeepAliveInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char KeepAliveInfoMarshaller::getDataStructureType() const { + return KeepAliveInfo::ID_KEEPALIVEINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void KeepAliveInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int KeepAliveInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + int rc = BaseCommandMarshaller::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 KeepAliveInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void KeepAliveInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void KeepAliveInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, 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/v1/KeepAliveInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.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_V1_KEEPALIVEINFOMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_KEEPALIVEINFOMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for KeepAliveInfoMarshaller + * + * 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 KeepAliveInfoMarshaller : public BaseCommandMarshaller { + public: + + KeepAliveInfoMarshaller() {} + virtual ~KeepAliveInfoMarshaller() {} + + /** + * 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_V1_KEEPALIVEINFOMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/KeepAliveInfoMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.cpp 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. + */ + +#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::v1; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* LastPartialCommandMarshaller::createObject() const { + return new LastPartialCommand(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char LastPartialCommandMarshaller::getDataStructureType() const { + return LastPartialCommand::ID_LASTPARTIALCOMMAND; +} + +/////////////////////////////////////////////////////////////////////////////// +void LastPartialCommandMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + PartialCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int LastPartialCommandMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + int rc = PartialCommandMarshaller::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 LastPartialCommandMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + PartialCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void LastPartialCommandMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + PartialCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void LastPartialCommandMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + PartialCommandMarshaller::looseMarshal( wireFormat, dataStructure, 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/v1/LastPartialCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.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_V1_LASTPARTIALCOMMANDMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_LASTPARTIALCOMMANDMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for LastPartialCommandMarshaller + * + * 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 LastPartialCommandMarshaller : public PartialCommandMarshaller { + public: + + LastPartialCommandMarshaller() {} + virtual ~LastPartialCommandMarshaller() {} + + /** + * 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_V1_LASTPARTIALCOMMANDMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LastPartialCommandMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,138 @@ +/* + * 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::v1; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* LocalTransactionIdMarshaller::createObject() const { + return new LocalTransactionId(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char LocalTransactionIdMarshaller::getDataStructureType() const { + return LocalTransactionId::ID_LOCALTRANSACTIONID; +} + +/////////////////////////////////////////////////////////////////////////////// +void LocalTransactionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + LocalTransactionId* info = + dynamic_cast( dataStructure ); + info->setValue( tightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setConnectionId( dynamic_cast< ConnectionId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int LocalTransactionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + LocalTransactionId* info = + dynamic_cast( dataStructure ); + + int rc = TransactionIdMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalLong1( wireFormat, info->getValue(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getConnectionId(), 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 LocalTransactionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + LocalTransactionId* info = + dynamic_cast( dataStructure ); + tightMarshalLong2( wireFormat, info->getValue(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getConnectionId(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void LocalTransactionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + TransactionIdMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + LocalTransactionId* info = + dynamic_cast( dataStructure ); + info->setValue( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setConnectionId( dynamic_cast< ConnectionId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void LocalTransactionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + LocalTransactionId* info = + dynamic_cast( dataStructure ); + TransactionIdMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalLong( wireFormat, info->getValue(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getConnectionId(), 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/v1/LocalTransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.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_V1_LOCALTRANSACTIONIDMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_LOCALTRANSACTIONIDMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for LocalTransactionIdMarshaller + * + * 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 LocalTransactionIdMarshaller : public TransactionIdMarshaller { + public: + + LocalTransactionIdMarshaller() {} + virtual ~LocalTransactionIdMarshaller() {} + + /** + * 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_V1_LOCALTRANSACTIONIDMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/LocalTransactionIdMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,152 @@ +/* + * 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 +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +/* + * + * Command and marshaling code for OpenWire format for MarshallerFactory + * + * + * 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 + * + */ + +using namespace activemq; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +void MarshallerFactory::configure( OpenWireFormat* format ) { + + format->addMarshaller( new ActiveMQBlobMessageMarshaller() ); + format->addMarshaller( new ActiveMQBytesMessageMarshaller() ); + format->addMarshaller( new ActiveMQMapMessageMarshaller() ); + format->addMarshaller( new ActiveMQMessageMarshaller() ); + format->addMarshaller( new ActiveMQObjectMessageMarshaller() ); + format->addMarshaller( new ActiveMQQueueMarshaller() ); + format->addMarshaller( new ActiveMQStreamMessageMarshaller() ); + format->addMarshaller( new ActiveMQTempQueueMarshaller() ); + format->addMarshaller( new ActiveMQTempTopicMarshaller() ); + format->addMarshaller( new ActiveMQTextMessageMarshaller() ); + format->addMarshaller( new ActiveMQTopicMarshaller() ); + format->addMarshaller( new BrokerIdMarshaller() ); + format->addMarshaller( new BrokerInfoMarshaller() ); + format->addMarshaller( new ConnectionControlMarshaller() ); + format->addMarshaller( new ConnectionErrorMarshaller() ); + format->addMarshaller( new ConnectionIdMarshaller() ); + format->addMarshaller( new ConnectionInfoMarshaller() ); + format->addMarshaller( new ConsumerControlMarshaller() ); + format->addMarshaller( new ConsumerIdMarshaller() ); + format->addMarshaller( new ConsumerInfoMarshaller() ); + format->addMarshaller( new ControlCommandMarshaller() ); + format->addMarshaller( new DataArrayResponseMarshaller() ); + format->addMarshaller( new DataResponseMarshaller() ); + format->addMarshaller( new DestinationInfoMarshaller() ); + format->addMarshaller( new DiscoveryEventMarshaller() ); + format->addMarshaller( new ExceptionResponseMarshaller() ); + format->addMarshaller( new FlushCommandMarshaller() ); + format->addMarshaller( new IntegerResponseMarshaller() ); + format->addMarshaller( new JournalQueueAckMarshaller() ); + format->addMarshaller( new JournalTopicAckMarshaller() ); + format->addMarshaller( new JournalTraceMarshaller() ); + format->addMarshaller( new JournalTransactionMarshaller() ); + format->addMarshaller( new KeepAliveInfoMarshaller() ); + format->addMarshaller( new LastPartialCommandMarshaller() ); + format->addMarshaller( new LocalTransactionIdMarshaller() ); + format->addMarshaller( new MessageAckMarshaller() ); + format->addMarshaller( new MessageDispatchMarshaller() ); + format->addMarshaller( new MessageDispatchNotificationMarshaller() ); + format->addMarshaller( new MessageIdMarshaller() ); + format->addMarshaller( new MessagePullMarshaller() ); + format->addMarshaller( new NetworkBridgeFilterMarshaller() ); + format->addMarshaller( new PartialCommandMarshaller() ); + format->addMarshaller( new ProducerAckMarshaller() ); + format->addMarshaller( new ProducerIdMarshaller() ); + format->addMarshaller( new ProducerInfoMarshaller() ); + format->addMarshaller( new RemoveInfoMarshaller() ); + format->addMarshaller( new RemoveSubscriptionInfoMarshaller() ); + format->addMarshaller( new ReplayCommandMarshaller() ); + format->addMarshaller( new ResponseMarshaller() ); + format->addMarshaller( new SessionIdMarshaller() ); + format->addMarshaller( new SessionInfoMarshaller() ); + format->addMarshaller( new ShutdownInfoMarshaller() ); + format->addMarshaller( new SubscriptionInfoMarshaller() ); + format->addMarshaller( new TransactionInfoMarshaller() ); + format->addMarshaller( new WireFormatInfoMarshaller() ); + format->addMarshaller( new XATransactionIdMarshaller() ); +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h Sun Jan 11 12:22:34 2009 @@ -0,0 +1,52 @@ +/* + * 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_V1_MARSHALERFACTORY_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_MARSHALERFACTORY_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Used to create marshallers for a specific version of the wire + * protocol. + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts + * in the activemq-openwire-generator module + */ + class MarshallerFactory { + public: + + virtual ~MarshallerFactory() {}; + + virtual void configure( OpenWireFormat* format ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSHAL_V1_MARSHALLERFACTORY_H_*/ Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MarshallerFactory.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,169 @@ +/* + * 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::v1; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* MessageAckMarshaller::createObject() const { + return new MessageAck(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char MessageAckMarshaller::getDataStructureType() const { + return MessageAck::ID_MESSAGEACK; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageAckMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + MessageAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setConsumerId( dynamic_cast< ConsumerId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setAckType( dataIn->readByte() ); + info->setFirstMessageId( dynamic_cast< MessageId* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ); + info->setLastMessageId( dynamic_cast< MessageId* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ); + info->setMessageCount( dataIn->readInt() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int MessageAckMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageAck* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getDestination(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getTransactionId(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getConsumerId(), bs ); + rc += tightMarshalNestedObject1( wireFormat, info->getFirstMessageId(), bs ); + rc += tightMarshalNestedObject1( wireFormat, info->getLastMessageId(), bs ); + + return rc + 5; + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageAckMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + MessageAck* info = + dynamic_cast( dataStructure ); + tightMarshalCachedObject2( wireFormat, info->getDestination(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getTransactionId(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getConsumerId(), dataOut, bs ); + dataOut->write( info->getAckType() ); + tightMarshalNestedObject2( wireFormat, info->getFirstMessageId(), dataOut, bs ); + tightMarshalNestedObject2( wireFormat, info->getLastMessageId(), dataOut, bs ); + dataOut->writeInt( info->getMessageCount() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageAckMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + MessageAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setConsumerId( dynamic_cast< ConsumerId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setAckType( dataIn->readByte() ); + info->setFirstMessageId( dynamic_cast< MessageId* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setLastMessageId( dynamic_cast< MessageId* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setMessageCount( dataIn->readInt() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageAckMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + MessageAck* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalCachedObject( wireFormat, info->getDestination(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getTransactionId(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getConsumerId(), dataOut ); + dataOut->write( info->getAckType() ); + looseMarshalNestedObject( wireFormat, info->getFirstMessageId(), dataOut ); + looseMarshalNestedObject( wireFormat, info->getLastMessageId(), dataOut ); + dataOut->writeInt( info->getMessageCount() ); + } + 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/v1/MessageAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.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_V1_MESSAGEACKMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_MESSAGEACKMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for MessageAckMarshaller + * + * 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 MessageAckMarshaller : public BaseCommandMarshaller { + public: + + MessageAckMarshaller() {} + virtual ~MessageAckMarshaller() {} + + /** + * 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_V1_MESSAGEACKMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageAckMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.cpp?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.cpp Sun Jan 11 12:22:34 2009 @@ -0,0 +1,151 @@ +/* + * 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::v1; +using namespace decaf; +using namespace decaf::io; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* MessageDispatchMarshaller::createObject() const { + return new MessageDispatch(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char MessageDispatchMarshaller::getDataStructureType() const { + return MessageDispatch::ID_MESSAGEDISPATCH; +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageDispatchMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + MessageDispatch* info = + dynamic_cast( dataStructure ); + info->setConsumerId( dynamic_cast< ConsumerId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ); + info->setMessage( dynamic_cast< Message* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ); + info->setRedeliveryCounter( dataIn->readInt() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int MessageDispatchMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + MessageDispatch* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getConsumerId(), bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getDestination(), bs ); + rc += tightMarshalNestedObject1( wireFormat, info->getMessage(), bs ); + + 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 MessageDispatchMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + MessageDispatch* info = + dynamic_cast( dataStructure ); + tightMarshalCachedObject2( wireFormat, info->getConsumerId(), dataOut, bs ); + tightMarshalCachedObject2( wireFormat, info->getDestination(), dataOut, bs ); + tightMarshalNestedObject2( wireFormat, info->getMessage(), dataOut, bs ); + dataOut->writeInt( info->getRedeliveryCounter() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageDispatchMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + MessageDispatch* info = + dynamic_cast( dataStructure ); + info->setConsumerId( dynamic_cast< ConsumerId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ); + info->setMessage( dynamic_cast< Message* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setRedeliveryCounter( dataIn->readInt() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void MessageDispatchMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + MessageDispatch* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalCachedObject( wireFormat, info->getConsumerId(), dataOut ); + looseMarshalCachedObject( wireFormat, info->getDestination(), dataOut ); + looseMarshalNestedObject( wireFormat, info->getMessage(), dataOut ); + dataOut->writeInt( info->getRedeliveryCounter() ); + } + 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/v1/MessageDispatchMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.h?rev=733509&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.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_V1_MESSAGEDISPATCHMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_MESSAGEDISPATCHMARSHALLER_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 v1{ + + /** + * Marshalling code for Open Wire Format for MessageDispatchMarshaller + * + * 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 MessageDispatchMarshaller : public BaseCommandMarshaller { + public: + + MessageDispatchMarshaller() {} + virtual ~MessageDispatchMarshaller() {} + + /** + * 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_V1_MESSAGEDISPATCHMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/wireformat/openwire/marshal/v1/MessageDispatchMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native