Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 83849 invoked from network); 2 Oct 2006 14:32:43 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 2 Oct 2006 14:32:43 -0000 Received: (qmail 72347 invoked by uid 500); 2 Oct 2006 14:32:43 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 72322 invoked by uid 500); 2 Oct 2006 14:32:42 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 72313 invoked by uid 99); 2 Oct 2006 14:32:42 -0000 Received: from idunn.apache.osuosl.org (HELO idunn.apache.osuosl.org) (140.211.166.84) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Oct 2006 07:32:42 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=5.0 tests=ALL_TRUSTED,NO_REAL_NAME Received: from [140.211.166.113] ([140.211.166.113:53189] helo=eris.apache.org) by idunn.apache.osuosl.org (ecelerity 2.1.1.8 r(12930)) with ESMTP id 6C/6B-16499-ED221254 for ; Mon, 02 Oct 2006 07:32:07 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 7F15C1A983A; Mon, 2 Oct 2006 07:30:38 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r452053 [12/17] - in /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/ main/activemq/connector/openwire/marshal/ main/activemq/connector/openwire/marshal/V2... Date: Mon, 02 Oct 2006 14:30:22 -0000 To: activemq-commits@geronimo.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20061002143038.7F15C1A983A@eris.apache.org> X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* DiscoveryEventMarshaller::createObject() const { + return new DiscoveryEvent(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char DiscoveryEventMarshaller::getDataStructureType() const { + return DiscoveryEvent::ID_DISCOVERYEVENT; +} + +/////////////////////////////////////////////////////////////////////////////// +void DiscoveryEventMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + DiscoveryEvent* info = + dynamic_cast( dataStructure ); + info->setServiceName( TightUnmarshalString( dataIn, bs ) ); + info->setBrokerName( TightUnmarshalString( dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int DiscoveryEventMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + DiscoveryEvent* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getServiceName(), bs ); + rc += tightMarshalString1( info->getBrokerName(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void DiscoveryEventMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + DiscoveryEvent* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getServiceName(), dataOut, bs ); + tightMarshalString2( info->getBrokerName(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void DiscoveryEventMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + DiscoveryEvent* info = + dynamic_cast( dataStructure ); + info->setServiceName( looseUnmarshalString( dataIn ) ); + info->setBrokerName( looseUnmarshalString( dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void DiscoveryEventMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + DiscoveryEvent* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getServiceName(), dataOut ); + looseMarshalString( info->getBrokerName(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_DISCOVERYEVENTMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_DISCOVERYEVENTMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for DiscoveryEventMarshaller + * + * 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 DiscoveryEventMarshaller : public BaseDataStreamMarshaller + { + public: + + DiscoveryEventMarshaller() {}; + virtual ~DiscoveryEventMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_DISCOVERYEVENTMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/DiscoveryEventMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ExceptionResponseMarshaller::createObject() const { + return new ExceptionResponse(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ExceptionResponseMarshaller::getDataStructureType() const { + return ExceptionResponse::ID_EXCEPTIONRESPONSE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ExceptionResponseMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + ResponseMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ExceptionResponse* info = + dynamic_cast( dataStructure ); + info->setException( dynamic_cast< Throwable* >( + tightUnmarsalThrowable( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int ExceptionResponseMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + ExceptionResponse* info = + dynamic_cast( dataStructure ); + + int rc = ResponseMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalBrokerError1( wireFormat, info->getException(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void ExceptionResponseMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + ResponseMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ExceptionResponse* info = + dynamic_cast( dataStructure ); + tightMarshalBrokerError2( wireFormat, info->getException(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void ExceptionResponseMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + ResponseMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ExceptionResponse* info = + dynamic_cast( dataStructure ); + info->setException( looseUnmarshalBrokerError( wireFormat, dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void ExceptionResponseMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + ExceptionResponse* info = + dynamic_cast( dataStructure ); + ResponseMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalBrokerError( wireFormat, info->getException(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_EXCEPTIONRESPONSEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_EXCEPTIONRESPONSEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for ExceptionResponseMarshaller + * + * 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 ExceptionResponseMarshaller : public ResponseMarshaller + { + public: + + ExceptionResponseMarshaller() {}; + virtual ~ExceptionResponseMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_EXCEPTIONRESPONSEMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/ExceptionResponseMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,79 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* FlushCommandMarshaller::createObject() const { + return new FlushCommand(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char FlushCommandMarshaller::getDataStructureType() const { + return FlushCommand::ID_FLUSHCOMMAND; +} + +/////////////////////////////////////////////////////////////////////////////// +void FlushCommandMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + +} + +/////////////////////////////////////////////////////////////////////////////// +int FlushCommandMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void FlushCommandMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + +} + +/////////////////////////////////////////////////////////////////////////////// +void FlushCommandMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); +} + +/////////////////////////////////////////////////////////////////////////////// +void FlushCommandMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_FLUSHCOMMANDMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_FLUSHCOMMANDMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for FlushCommandMarshaller + * + * 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 FlushCommandMarshaller : public BaseCommandMarshaller + { + public: + + FlushCommandMarshaller() {}; + virtual ~FlushCommandMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_FLUSHCOMMANDMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/FlushCommandMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,94 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* IntegerResponseMarshaller::createObject() const { + return new IntegerResponse(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char IntegerResponseMarshaller::getDataStructureType() const { + return IntegerResponse::ID_INTEGERRESPONSE; +} + +/////////////////////////////////////////////////////////////////////////////// +void IntegerResponseMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + ResponseMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + IntegerResponse* info = + dynamic_cast( dataStructure ); + info->setResult( dataIn->readInt() ); +} + +/////////////////////////////////////////////////////////////////////////////// +int IntegerResponseMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + IntegerResponse* info = + dynamic_cast( dataStructure ); + + int rc = ResponseMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 4; +} + +/////////////////////////////////////////////////////////////////////////////// +void IntegerResponseMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + ResponseMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + IntegerResponse* info = + dynamic_cast( dataStructure ); + dataOut->write( info->getResult() ); +} + +/////////////////////////////////////////////////////////////////////////////// +void IntegerResponseMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + ResponseMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + IntegerResponse* info = + dynamic_cast( dataStructure ); + info->setResult( dataIn->readInt() ); +} + +/////////////////////////////////////////////////////////////////////////////// +void IntegerResponseMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + IntegerResponse* info = + dynamic_cast( dataStructure ); + ResponseMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->write( info->getResult() ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_INTEGERRESPONSEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_INTEGERRESPONSEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for IntegerResponseMarshaller + * + * 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 IntegerResponseMarshaller : public ResponseMarshaller + { + public: + + IntegerResponseMarshaller() {}; + virtual ~IntegerResponseMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_INTEGERRESPONSEMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/IntegerResponseMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* JournalQueueAckMarshaller::createObject() const { + return new JournalQueueAck(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char JournalQueueAckMarshaller::getDataStructureType() const { + return JournalQueueAck::ID_JOURNALQUEUEACK; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalQueueAckMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + JournalQueueAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setMessageAck( dynamic_cast< MessageAck* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int JournalQueueAckMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + JournalQueueAck* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageAck() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalQueueAckMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + JournalQueueAck* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageAck() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalQueueAckMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + JournalQueueAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setMessageAck( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalQueueAckMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + JournalQueueAck* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageAck() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALQUEUEACKMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALQUEUEACKMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for JournalQueueAckMarshaller + * + * 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 JournalQueueAckMarshaller : public BaseDataStreamMarshaller + { + public: + + JournalQueueAckMarshaller() {}; + virtual ~JournalQueueAckMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALQUEUEACKMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalQueueAckMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -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::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* JournalTopicAckMarshaller::createObject() const { + return new JournalTopicAck(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTopicAckMarshaller::getDataStructureType() const { + return JournalTopicAck::ID_JOURNALTOPICACK; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTopicAckMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + JournalTopicAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast< ActiveMQDestination* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setMessageId( dynamic_cast< MessageId* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setMessageSequenceId( TightUnmarshalLong( wireFormat, dataIn, bs ) ); + info->setSubscritionName( TightUnmarshalString( dataIn, bs ) ); + info->setClientId( TightUnmarshalString( dataIn, bs ) ); + info->setTransactionId( dynamic_cast< TransactionId* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int JournalTopicAckMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + JournalTopicAck* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + rc += tightMarshalLong1( wireFormat, info->getMessageSequenceId(), bs ); + rc += tightMarshalString1( info->getSubscritionName(), bs ); + rc += tightMarshalString1( info->getClientId(), bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTopicAckMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + JournalTopicAck* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + tightMarshalLong2( wireFormat, info->getMessageSequenceId(), dataOut, bs ); + tightMarshalString2( info->getSubscritionName(), dataOut, bs ); + tightMarshalString2( info->getClientId(), dataOut, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTopicAckMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + JournalTopicAck* info = + dynamic_cast( dataStructure ); + info->setDestination( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setMessageId( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setMessageSequenceId( looseUnmarshalLong( wireFormat, dataIn ) ); + info->setSubscritionName( looseUnmarshalString( dataIn ) ); + info->setClientId( looseUnmarshalString( dataIn ) ); + info->setTransactionId( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTopicAckMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + JournalTopicAck* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getDestination() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getMessageId() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + looseMarshalLong( wireFormat, info->getMessageSequenceId(), dataOut ); + looseMarshalString( info->getSubscritionName(), dataOut ); + looseMarshalString( info->getClientId(), dataOut ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTOPICACKMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTOPICACKMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for JournalTopicAckMarshaller + * + * 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 JournalTopicAckMarshaller : public BaseDataStreamMarshaller + { + public: + + JournalTopicAckMarshaller() {}; + virtual ~JournalTopicAckMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTOPICACKMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTopicAckMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -0,0 +1,95 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* JournalTraceMarshaller::createObject() const { + return new JournalTrace(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTraceMarshaller::getDataStructureType() const { + return JournalTrace::ID_JOURNALTRACE; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTraceMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + JournalTrace* info = + dynamic_cast( dataStructure ); + info->setMessage( TightUnmarshalString( dataIn, bs ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +int JournalTraceMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + JournalTrace* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getMessage(), bs ); + + return rc + 0; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTraceMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + JournalTrace* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getMessage(), dataOut, bs ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTraceMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + JournalTrace* info = + dynamic_cast( dataStructure ); + info->setMessage( looseUnmarshalString( dataIn ) ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTraceMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + JournalTrace* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getMessage(), dataOut ); +} + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.h URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.h?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.h (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.h Mon Oct 2 07:30:10 2006 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTRACEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTRACEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v2{ + + /** + * Marshalling code for Open Wire Format for JournalTraceMarshaller + * + * 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 JournalTraceMarshaller : public BaseDataStreamMarshaller + { + public: + + JournalTraceMarshaller() {}; + virtual ~JournalTraceMarshaller() {}; + + /** + * Creates a new instance of this marshalable type. + * @return new DataStructure object pointer caller owns it. + */ + virtual DataStructure* createObject() const; + + /** + * Get the Data Structure Type that identifies this Marshaller + * @return byte holding the data structure type value + */ + virtual unsigned char getDataStructureType() const; + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be un-marshaled + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + util::BooleanStream* bs ) throws( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + BooleanStream* bs ) throws( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throws( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throws( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V2_JOURNALTRACEMARSHALLER_H_*/ + Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTraceMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTransactionMarshaller.cpp URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTransactionMarshaller.cpp?view=auto&rev=452053 ============================================================================== --- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTransactionMarshaller.cpp (added) +++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/V2/JournalTransactionMarshaller.cpp Mon Oct 2 07:30:10 2006 @@ -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 + +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::util; +using namespace activemq::connector::openwire::marshal::v2; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* JournalTransactionMarshaller::createObject() const { + return new JournalTransaction(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTransactionMarshaller::getDataStructureType() const { + return JournalTransaction::ID_JOURNALTRANSACTION; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTransactionMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) { + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + JournalTransaction* info = + dynamic_cast( dataStructure ); + info->setTransactionId( dynamic_cast< TransactionId* >( + tightUnmarsalNestedObject( wireFormat, dataIn, bs ) ); + info->setType( dataIn->readByte() ); + info->setWasPrepared( bs->readBoolean() ); +} + +/////////////////////////////////////////////////////////////////////////////// +int JournalTransactionMarshaller::tightMarshal1( OpenWireFormat& wireFormat, DataStructure* dataStructure, BooleanStream& bs ) { + + JournalTransaction* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + rc += tightMarshalNestedObject1( wireFormat, data, bs ); + bs->writeBoolean( info->getWasPrepared() ); + + return rc + 1; +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTransactionMarshaller::tightMarshal2( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut, BooleanStream& bs ) { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + JournalTransaction* info = + dynamic_cast( dataStructure ); + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + tightMarshalNestedObject2( wireFormat, data, dataOut, bs ); + dataOut->write( info->getType() ); + bs->readBoolean(); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTransactionMarshaller::looseUnmarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataInputStream& dataIn ) { + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + JournalTransaction* info = + dynamic_cast( dataStructure ); + info->setTransactionId( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ); + info->setType( dataIn->readByte() ); + info->setWasPrepared( dataIn->readBoolean() ); +} + +/////////////////////////////////////////////////////////////////////////////// +void JournalTransactionMarshaller::looseMarshal( OpenWireFormat& wireFormat, DataStructure* dataStructure, DataOutputStream& dataOut ) { + JournalTransaction* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + DataStructure* data = + dynamic_cast< DataStructure* >( info->getTransactionId() ); + + looseMarshalNestedObject( wireFormat, data, dataOut ); + dataOut->write( info->getType() ); + dataOut->write( info->getWasPrepared() ); +} +