Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/BrokerInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/BrokerInfoMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/BrokerInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/BrokerInfoMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_BROKERINFOMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_BROKERINFOMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for BrokerInfoMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API BrokerInfoMarshaller : public BaseCommandMarshaller { + public: + + BrokerInfoMarshaller() {} + virtual ~BrokerInfoMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_BROKERINFOMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/BrokerInfoMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.cpp?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.cpp Tue Jun 8 22:47:47 2010 @@ -0,0 +1,168 @@ +/* + * 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 + +// +// 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::v6; +using namespace decaf; +using namespace decaf::io; +using namespace decaf::lang; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ConnectionControlMarshaller::createObject() const { + return new ConnectionControl(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ConnectionControlMarshaller::getDataStructureType() const { + return ConnectionControl::ID_CONNECTIONCONTROL; +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionControlMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ConnectionControl* info = + dynamic_cast( dataStructure ); + info->setClose( bs->readBoolean() ); + info->setExit( bs->readBoolean() ); + info->setFaultTolerant( bs->readBoolean() ); + info->setResume( bs->readBoolean() ); + info->setSuspend( bs->readBoolean() ); + info->setConnectedBrokers( tightUnmarshalString( dataIn, bs ) ); + info->setReconnectTo( tightUnmarshalString( dataIn, bs ) ); + info->setRebalanceConnection( bs->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ConnectionControlMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ConnectionControl* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + bs->writeBoolean( info->isClose() ); + bs->writeBoolean( info->isExit() ); + bs->writeBoolean( info->isFaultTolerant() ); + bs->writeBoolean( info->isResume() ); + bs->writeBoolean( info->isSuspend() ); + rc += tightMarshalString1( info->getConnectedBrokers(), bs ); + rc += tightMarshalString1( info->getReconnectTo(), bs ); + bs->writeBoolean( info->isRebalanceConnection() ); + + 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 ConnectionControlMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ConnectionControl* info = + dynamic_cast( dataStructure ); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + tightMarshalString2( info->getConnectedBrokers(), dataOut, bs ); + tightMarshalString2( info->getReconnectTo(), dataOut, bs ); + bs->readBoolean(); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionControlMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ConnectionControl* info = + dynamic_cast( dataStructure ); + info->setClose( dataIn->readBoolean() ); + info->setExit( dataIn->readBoolean() ); + info->setFaultTolerant( dataIn->readBoolean() ); + info->setResume( dataIn->readBoolean() ); + info->setSuspend( dataIn->readBoolean() ); + info->setConnectedBrokers( looseUnmarshalString( dataIn ) ); + info->setReconnectTo( looseUnmarshalString( dataIn ) ); + info->setRebalanceConnection( dataIn->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionControlMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ConnectionControl* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + dataOut->writeBoolean( info->isClose() ); + dataOut->writeBoolean( info->isExit() ); + dataOut->writeBoolean( info->isFaultTolerant() ); + dataOut->writeBoolean( info->isResume() ); + dataOut->writeBoolean( info->isSuspend() ); + looseMarshalString( info->getConnectedBrokers(), dataOut ); + looseMarshalString( info->getReconnectTo(), dataOut ); + dataOut->writeBoolean( info->isRebalanceConnection() ); + } + 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/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONCONTROLMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONCONTROLMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for ConnectionControlMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API ConnectionControlMarshaller : public BaseCommandMarshaller { + public: + + ConnectionControlMarshaller() {} + virtual ~ConnectionControlMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONCONTROLMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionControlMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.cpp?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.cpp Tue Jun 8 22:47:47 2010 @@ -0,0 +1,142 @@ +/* + * 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 + +// +// 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::v6; +using namespace decaf; +using namespace decaf::io; +using namespace decaf::lang; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ConnectionErrorMarshaller::createObject() const { + return new ConnectionError(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ConnectionErrorMarshaller::getDataStructureType() const { + return ConnectionError::ID_CONNECTIONERROR; +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionErrorMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ConnectionError* info = + dynamic_cast( dataStructure ); + info->setException( Pointer( dynamic_cast< BrokerError* >( + tightUnmarshalBrokerError( wireFormat, dataIn, bs ) ) ) ); + info->setConnectionId( Pointer( dynamic_cast< ConnectionId* >( + tightUnmarshalNestedObject( 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 ConnectionErrorMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ConnectionError* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalBrokerError1( wireFormat, info->getException().get(), bs ); + rc += tightMarshalNestedObject1( wireFormat, info->getConnectionId().get(), 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 ConnectionErrorMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ConnectionError* info = + dynamic_cast( dataStructure ); + tightMarshalBrokerError2( wireFormat, info->getException().get(), dataOut, bs ); + tightMarshalNestedObject2( wireFormat, info->getConnectionId().get(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionErrorMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ConnectionError* info = + dynamic_cast( dataStructure ); + info->setException( Pointer( dynamic_cast< BrokerError* >( + looseUnmarshalBrokerError( wireFormat, dataIn ) ) ) ); + info->setConnectionId( Pointer( dynamic_cast< ConnectionId* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionErrorMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ConnectionError* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalBrokerError( wireFormat, info->getException().get(), dataOut ); + looseMarshalNestedObject( wireFormat, info->getConnectionId().get(), 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/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONERRORMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONERRORMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for ConnectionErrorMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API ConnectionErrorMarshaller : public BaseCommandMarshaller { + public: + + ConnectionErrorMarshaller() {} + virtual ~ConnectionErrorMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONERRORMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionErrorMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.cpp?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.cpp Tue Jun 8 22:47:47 2010 @@ -0,0 +1,133 @@ +/* + * 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 + +// +// 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::v6; +using namespace decaf; +using namespace decaf::io; +using namespace decaf::lang; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ConnectionIdMarshaller::createObject() const { + return new ConnectionId(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ConnectionIdMarshaller::getDataStructureType() const { + return ConnectionId::ID_CONNECTIONID; +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ConnectionId* info = + dynamic_cast( dataStructure ); + info->setValue( tightUnmarshalString( dataIn, bs ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ConnectionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ConnectionId* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getValue(), 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 ConnectionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ConnectionId* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getValue(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ConnectionId* info = + dynamic_cast( dataStructure ); + info->setValue( looseUnmarshalString( dataIn ) ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ConnectionId* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getValue(), 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/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONIDMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONIDMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for ConnectionIdMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API ConnectionIdMarshaller : public BaseDataStreamMarshaller { + public: + + ConnectionIdMarshaller() {} + virtual ~ConnectionIdMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONIDMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionIdMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.cpp?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.cpp Tue Jun 8 22:47:47 2010 @@ -0,0 +1,197 @@ +/* + * 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 + +// +// 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::v6; +using namespace decaf; +using namespace decaf::io; +using namespace decaf::lang; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ConnectionInfoMarshaller::createObject() const { + return new ConnectionInfo(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ConnectionInfoMarshaller::getDataStructureType() const { + return ConnectionInfo::ID_CONNECTIONINFO; +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ConnectionInfo* info = + dynamic_cast( dataStructure ); + info->setConnectionId( Pointer( dynamic_cast< ConnectionId* >( + tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ) ); + info->setClientId( tightUnmarshalString( dataIn, bs ) ); + info->setPassword( tightUnmarshalString( dataIn, bs ) ); + info->setUserName( tightUnmarshalString( dataIn, bs ) ); + + if( bs->readBoolean() ) { + short size = dataIn->readShort(); + info->getBrokerPath().reserve( size ); + for( int i = 0; i < size; i++ ) { + info->getBrokerPath().push_back( Pointer( dynamic_cast< BrokerId* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) ); + } + } + else { + info->getBrokerPath().clear(); + } + info->setBrokerMasterConnector( bs->readBoolean() ); + info->setManageable( bs->readBoolean() ); + info->setClientMaster( bs->readBoolean() ); + info->setFaultTolerant( bs->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ConnectionInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ConnectionInfo* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalCachedObject1( wireFormat, info->getConnectionId().get(), bs ); + rc += tightMarshalString1( info->getClientId(), bs ); + rc += tightMarshalString1( info->getPassword(), bs ); + rc += tightMarshalString1( info->getUserName(), bs ); + rc += tightMarshalObjectArray1( wireFormat, info->getBrokerPath(), bs ); + bs->writeBoolean( info->isBrokerMasterConnector() ); + bs->writeBoolean( info->isManageable() ); + bs->writeBoolean( info->isClientMaster() ); + bs->writeBoolean( info->isFaultTolerant() ); + + 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 ConnectionInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ConnectionInfo* info = + dynamic_cast( dataStructure ); + tightMarshalCachedObject2( wireFormat, info->getConnectionId().get(), dataOut, bs ); + tightMarshalString2( info->getClientId(), dataOut, bs ); + tightMarshalString2( info->getPassword(), dataOut, bs ); + tightMarshalString2( info->getUserName(), dataOut, bs ); + tightMarshalObjectArray2( wireFormat, info->getBrokerPath(), dataOut, bs ); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ConnectionInfo* info = + dynamic_cast( dataStructure ); + info->setConnectionId( Pointer( dynamic_cast< ConnectionId* >( + looseUnmarshalCachedObject( wireFormat, dataIn ) ) ) ); + info->setClientId( looseUnmarshalString( dataIn ) ); + info->setPassword( looseUnmarshalString( dataIn ) ); + info->setUserName( looseUnmarshalString( dataIn ) ); + + if( dataIn->readBoolean() ) { + short size = dataIn->readShort(); + info->getBrokerPath().reserve( size ); + for( int i = 0; i < size; i++ ) { + info->getBrokerPath().push_back( Pointer( dynamic_cast( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) ); + } + } + else { + info->getBrokerPath().clear(); + } + info->setBrokerMasterConnector( dataIn->readBoolean() ); + info->setManageable( dataIn->readBoolean() ); + info->setClientMaster( dataIn->readBoolean() ); + info->setFaultTolerant( dataIn->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConnectionInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ConnectionInfo* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalCachedObject( wireFormat, info->getConnectionId().get(), dataOut ); + looseMarshalString( info->getClientId(), dataOut ); + looseMarshalString( info->getPassword(), dataOut ); + looseMarshalString( info->getUserName(), dataOut ); + looseMarshalObjectArray( wireFormat, info->getBrokerPath(), dataOut ); + dataOut->writeBoolean( info->isBrokerMasterConnector() ); + dataOut->writeBoolean( info->isManageable() ); + dataOut->writeBoolean( info->isClientMaster() ); + dataOut->writeBoolean( info->isFaultTolerant() ); + } + 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/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONINFOMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONINFOMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for ConnectionInfoMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API ConnectionInfoMarshaller : public BaseCommandMarshaller { + public: + + ConnectionInfoMarshaller() {} + virtual ~ConnectionInfoMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONNECTIONINFOMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConnectionInfoMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.cpp?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.cpp Tue Jun 8 22:47:47 2010 @@ -0,0 +1,166 @@ +/* + * 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 + +// +// 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::v6; +using namespace decaf; +using namespace decaf::io; +using namespace decaf::lang; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ConsumerControlMarshaller::createObject() const { + return new ConsumerControl(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ConsumerControlMarshaller::getDataStructureType() const { + return ConsumerControl::ID_CONSUMERCONTROL; +} + +/////////////////////////////////////////////////////////////////////////////// +void ConsumerControlMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ConsumerControl* info = + dynamic_cast( dataStructure ); + info->setDestination( Pointer( dynamic_cast< ActiveMQDestination* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) ); + info->setClose( bs->readBoolean() ); + info->setConsumerId( Pointer( dynamic_cast< ConsumerId* >( + tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) ); + info->setPrefetch( dataIn->readInt() ); + info->setFlush( bs->readBoolean() ); + info->setStart( bs->readBoolean() ); + info->setStop( bs->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ConsumerControlMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + ConsumerControl* info = + dynamic_cast( dataStructure ); + + int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalNestedObject1( wireFormat, info->getDestination().get(), bs ); + bs->writeBoolean( info->isClose() ); + rc += tightMarshalNestedObject1( wireFormat, info->getConsumerId().get(), bs ); + bs->writeBoolean( info->isFlush() ); + bs->writeBoolean( info->isStart() ); + bs->writeBoolean( info->isStop() ); + + 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 ConsumerControlMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ConsumerControl* info = + dynamic_cast( dataStructure ); + tightMarshalNestedObject2( wireFormat, info->getDestination().get(), dataOut, bs ); + bs->readBoolean(); + tightMarshalNestedObject2( wireFormat, info->getConsumerId().get(), dataOut, bs ); + dataOut->writeInt( info->getPrefetch() ); + bs->readBoolean(); + bs->readBoolean(); + bs->readBoolean(); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConsumerControlMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( decaf::io::IOException ) { + + try { + + BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ConsumerControl* info = + dynamic_cast( dataStructure ); + info->setDestination( Pointer( dynamic_cast< ActiveMQDestination* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) ); + info->setClose( dataIn->readBoolean() ); + info->setConsumerId( Pointer( dynamic_cast< ConsumerId* >( + looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) ); + info->setPrefetch( dataIn->readInt() ); + info->setFlush( dataIn->readBoolean() ); + info->setStart( dataIn->readBoolean() ); + info->setStop( dataIn->readBoolean() ); + } + AMQ_CATCH_RETHROW( decaf::io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException ) + AMQ_CATCHALL_THROW( decaf::io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ConsumerControlMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( decaf::io::IOException ) { + + try { + + ConsumerControl* info = + dynamic_cast( dataStructure ); + BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalNestedObject( wireFormat, info->getDestination().get(), dataOut ); + dataOut->writeBoolean( info->isClose() ); + looseMarshalNestedObject( wireFormat, info->getConsumerId().get(), dataOut ); + dataOut->writeInt( info->getPrefetch() ); + dataOut->writeBoolean( info->isFlush() ); + dataOut->writeBoolean( info->isStart() ); + dataOut->writeBoolean( info->isStop() ); + } + 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/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.h?rev=952853&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.h (added) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.h Tue Jun 8 22:47:47 2010 @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONSUMERCONTROLMARSHALLER_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONSUMERCONTROLMARSHALLER_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 v6{ + + /** + * Marshaling code for Open Wire Format for ConsumerControlMarshaller + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class AMQCPP_API ConsumerControlMarshaller : public BaseCommandMarshaller { + public: + + ConsumerControlMarshaller() {} + virtual ~ConsumerControlMarshaller() {} + + /** + * 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 Marshaler + * + * @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 - describes the wire format of the broker. + * @param dataStructure - Object to be un-marshaled. + * @param dataIn - BinaryReader that provides that data. + * @param bs - BooleanStream stream used to unpack bits from the wire. + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param bs - BooleanStream stream used to pack bits from the wire. + * @returns int value indicating the size of the marshaled object. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream stream used to pack bits from the wire. + * + * @throws IOException if an error occurs during the marshal. + */ + 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 - describes the wire format of the broker + * @param dataStructure - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + * + * @throws IOException if an error occurs during the unmarshal. + */ + 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 dataStructure - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + * + * @throws IOException if an error occurs during the marshal. + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + decaf::io::DataOutputStream* dataOut ) throw( decaf::io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V6_CONSUMERCONTROLMARSHALLER_H_*/ + Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/v6/ConsumerControlMarshaller.h ------------------------------------------------------------------------------ svn:eol-style = native