activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r733487 [10/10] - /activemq/activemq-cpp/trunk/src/main/activemq/commands/
Date Sun, 11 Jan 2009 16:36:05 GMT
Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,189 @@
+/*
+ * 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 <activemq/commands/TransactionInfo.h>
+#include <activemq/exceptions/ActiveMQException.h>
+#include <decaf/lang/exceptions/NullPointerException.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::commands;
+using namespace decaf::lang::exceptions;
+
+/*
+ *
+ *  Command and marshaling code for OpenWire format for TransactionInfo
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+TransactionInfo::TransactionInfo()
+{
+    this->connectionId = NULL;
+    this->transactionId = NULL;
+    this->type = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionInfo::~TransactionInfo()
+{
+    delete this->connectionId;
+    delete this->transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionInfo* TransactionInfo::cloneDataStructure() const {
+    TransactionInfo* transactionInfo = new TransactionInfo();
+
+    // Copy the data from the base class or classes
+    transactionInfo->copyDataStructure( this );
+
+    return transactionInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void TransactionInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const TransactionInfo* srcPtr = dynamic_cast<const TransactionInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "TransactionInfo::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getConnectionId() != NULL ) {
+        this->setConnectionId(
+            dynamic_cast<ConnectionId*>(
+                srcPtr->getConnectionId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getTransactionId() != NULL ) {
+        this->setTransactionId(
+            dynamic_cast<TransactionId*>(
+                srcPtr->getTransactionId()->cloneDataStructure() ) );
+    }
+    this->setType( srcPtr->getType() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char TransactionInfo::getDataStructureType() const {
+    return TransactionInfo::ID_TRANSACTIONINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string TransactionInfo::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = TransactionInfo" << std::endl;
+    stream << " Value of TransactionInfo::ID_TRANSACTIONINFO = 7" << std::endl;
+    stream << " Value of ConnectionId is Below:" << std::endl;
+    if( this->getConnectionId() != NULL ) {
+        stream << this->getConnectionId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of TransactionId is Below:" << std::endl;
+    if( this->getTransactionId() != NULL ) {
+        stream << this->getTransactionId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Type = " << (int)this->getType() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = TransactionInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool TransactionInfo::equals( const DataStructure* value ) const {
+    const TransactionInfo* valuePtr = dynamic_cast<const TransactionInfo*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getConnectionId() != NULL ) {
+        if( !this->getConnectionId()->equals( valuePtr->getConnectionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getConnectionId() != NULL ) {
+        return false;
+    }
+    if( this->getTransactionId() != NULL ) {
+        if( !this->getTransactionId()->equals( valuePtr->getTransactionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getTransactionId() != NULL ) {
+        return false;
+    }
+    if( this->getType() != valuePtr->getType() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* TransactionInfo::getConnectionId() const {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* TransactionInfo::getConnectionId() {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void TransactionInfo::setConnectionId(ConnectionId* connectionId ) {
+    this->connectionId = connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* TransactionInfo::getTransactionId() const {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* TransactionInfo::getTransactionId() {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void TransactionInfo::setTransactionId(TransactionId* transactionId ) {
+    this->transactionId = transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char TransactionInfo::getType() const {
+    return type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void TransactionInfo::setType(unsigned char type ) {
+    this->type = type;
+}
+

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_COMMANDS_TRANSACTIONINFO_H_
+#define _ACTIVEMQ_COMMANDS_TRANSACTIONINFO_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/util/Config.h>
+#include <activemq/commands/BaseCommand.h>
+#include <activemq/commands/ConnectionId.h>
+#include <activemq/commands/TransactionId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for TransactionInfo
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class AMQCPP_API TransactionInfo : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ConnectionId* connectionId;
+        TransactionId* transactionId;
+        unsigned char type;
+
+    public:
+
+        const static unsigned char ID_TRANSACTIONINFO = 7;
+
+    public:
+
+        TransactionInfo();
+        virtual ~TransactionInfo();
+
+        /**
+         * Get the unique identifier that this object and its own
+         * Marshaller share.
+         * @returns new DataStructure type copy.
+         */
+        virtual unsigned char getDataStructureType() const;
+
+        /**
+         * Clone this object and return a new instance that the
+         * caller now owns, this will be an exact copy of this one
+         * @returns new copy of this object.
+         */
+        virtual TransactionInfo* cloneDataStructure() const;
+
+        /**
+         * Copy the contents of the passed object into this object's
+         * members, overwriting any existing data.
+         * @param src - Source Object
+         */
+        virtual void copyDataStructure( const DataStructure* src );
+
+        /**
+         * Returns a string containing the information for this DataStructure
+         * such as its type and value of its elements.
+         * @return formatted string useful for debugging.
+         */
+        virtual std::string toString() const;
+
+        /**
+         * Compares the DataStructure passed in to this one, and returns if
+         * they are equivalent.  Equivalent here means that they are of the
+         * same type, and that each element of the objects are the same.
+         * @returns true if DataStructure's are Equal.
+         */
+        virtual bool equals( const DataStructure* value ) const;
+
+        virtual const ConnectionId* getConnectionId() const;
+        virtual ConnectionId* getConnectionId();
+        virtual void setConnectionId( ConnectionId* connectionId );
+
+        virtual const TransactionId* getTransactionId() const;
+        virtual TransactionId* getTransactionId();
+        virtual void setTransactionId( TransactionId* transactionId );
+
+        virtual unsigned char getType() const;
+        virtual void setType( unsigned char type );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_TRANSACTIONINFO_H_*/
+

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/TransactionInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,326 @@
+/**
+ * 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 <activemq/commands/WireFormatInfo.h>
+
+#include <activemq/wireformat/openwire/marshal/PrimitiveMapMarshaller.h>
+#include <decaf/lang/exceptions/NullPointerException.h>
+
+using namespace std;
+using namespace decaf;
+using namespace decaf::lang;
+using namespace decaf::lang::exceptions;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::wireformat;
+using namespace activemq::wireformat::openwire;
+using namespace activemq::wireformat::openwire::marshal;
+using namespace activemq::commands;
+
+////////////////////////////////////////////////////////////////////////////////
+WireFormatInfo::WireFormatInfo()
+{
+    // Init to our preferred version
+    this->version = 2;
+
+    // Initialize the MAGIC buffer.
+    magic.push_back( 'A' );
+    magic.push_back( 'c' );
+    magic.push_back( 't' );
+    magic.push_back( 'i' );
+    magic.push_back( 'v' );
+    magic.push_back( 'e' );
+    magic.push_back( 'M' );
+    magic.push_back( 'Q' );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+WireFormatInfo::~WireFormatInfo() {
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* WireFormatInfo::cloneDataStructure() const {
+    WireFormatInfo* wireFormatInfo = new WireFormatInfo();
+
+    // Copy the data from the base class or classes
+    wireFormatInfo->copyDataStructure( this );
+
+    return wireFormatInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseDataStructure::copyDataStructure( src );
+
+    const WireFormatInfo* srcPtr = dynamic_cast<const WireFormatInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+        throw NullPointerException(
+            __FILE__, __LINE__,
+            "WireFormatInfo::copyDataStructure - src is NULL or invalid" );
+    }
+
+    this->properties.copy( srcPtr->getProperties() );
+    this->version = srcPtr->getVersion();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char WireFormatInfo::getDataStructureType() const {
+    return WireFormatInfo::ID_WIREFORMATINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string WireFormatInfo::toString() const {
+    std::ostringstream stream;
+
+    stream << "Begin Class = WireFormatInfo" << std::endl;
+
+    std::vector<unsigned char> magic;
+    std::vector<unsigned char> marshalledProperties;
+
+    for( size_t imagic = 0; imagic < magic.size(); ++imagic ) {
+        stream << " Value of magic[" << imagic << "] = " << magic[imagic] << std::endl;
+    }
+
+    for( size_t imarshalledProperties = 0; imarshalledProperties < marshalledProperties.size(); ++imarshalledProperties ) {
+        stream << " Value of marshalledProperties[" << imarshalledProperties << "] = "
+               << marshalledProperties[imarshalledProperties] << std::endl;
+    }
+
+    stream << " Value of properties = " << properties.toString() << std::endl;
+    stream << " Value of version = " << version << std::endl;
+    stream << " Value of stackTraceEnabled = " << isStackTraceEnabled() << std::endl;
+    stream << " Value of tcpNoDelayEnabled = " << isTcpNoDelayEnabled() << std::endl;
+    stream << " Value of cacheEnabled = " << isCacheEnabled() << std::endl;
+    stream << " Value of tightEncodingEnabled = " << isTightEncodingEnabled() << std::endl;
+    stream << " Value of sizePrefixDisabled = " << isSizePrefixDisabled() << std::endl;
+
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = WireFormatInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::equals( const DataStructure* value ) const {
+
+    const WireFormatInfo* wireFormatInfo =
+        dynamic_cast<const WireFormatInfo*>( value );
+
+    if( value == NULL || wireFormatInfo == NULL ) {
+        return false;
+    }
+
+    if( magic != wireFormatInfo->getMagic() ) {
+        return false;
+    }
+    if( marshalledProperties != wireFormatInfo->getMarshalledProperties() ) {
+        return false;
+    }
+    if( !properties.equals( wireFormatInfo->properties ) ) {
+        return false;
+    }
+    if( version != wireFormatInfo->getVersion() ) {
+        return false;
+    }
+    if( isStackTraceEnabled() != wireFormatInfo->isStackTraceEnabled() ) {
+        return false;
+    }
+    if( isTcpNoDelayEnabled() != wireFormatInfo->isTcpNoDelayEnabled() ) {
+        return false;
+    }
+    if( isCacheEnabled() != wireFormatInfo->isCacheEnabled() ) {
+        return false;
+    }
+    if( isTightEncodingEnabled() != wireFormatInfo->isTightEncodingEnabled() ) {
+        return false;
+    }
+    if( isSizePrefixDisabled() != wireFormatInfo->isSizePrefixDisabled() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isValid() const {
+
+    if( magic.size() != std::string( "ActiveMQ" ).size() ) {
+        return false;
+    }
+
+    if( magic[0] != 'A' ||
+        magic[1] != 'c' ||
+        magic[2] != 't' ||
+        magic[3] != 'i' ||
+        magic[4] != 'v' ||
+        magic[5] != 'e' ||
+        magic[6] != 'M' ||
+        magic[7] != 'Q' ) {
+
+        return false;
+    }
+
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isStackTraceEnabled() const {
+
+    try {
+        return properties.getBool( "StackTraceEnabled" );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+
+    return false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::setStackTraceEnabled( bool stackTraceEnabled ) {
+
+    try {
+        properties.setBool( "StackTraceEnabled", stackTraceEnabled );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isTcpNoDelayEnabled() const {
+
+    try {
+        return properties.getBool( "TcpNoDelayEnabled" );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+
+    return false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::setTcpNoDelayEnabled( bool tcpNoDelayEnabled ) {
+
+    try {
+        properties.setBool( "TcpNoDelayEnabled", tcpNoDelayEnabled );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isCacheEnabled() const {
+
+    try {
+        return properties.getBool( "CacheEnabled" );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+
+    return false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::setCacheEnabled( bool cacheEnabled ) {
+
+    try {
+        properties.setBool( "CacheEnabled", cacheEnabled );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isTightEncodingEnabled() const {
+
+    try {
+        return properties.getBool( "TightEncodingEnabled" );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+
+    return false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::setTightEncodingEnabled( bool tightEncodingEnabled ) {
+
+    try {
+        properties.setBool( "TightEncodingEnabled", tightEncodingEnabled );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool WireFormatInfo::isSizePrefixDisabled() const {
+
+    try {
+        return properties.getBool( "SizePrefixDisabled" );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+
+    return false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::setSizePrefixDisabled( bool sizePrefixDisabled ) {
+
+    try {
+        properties.setBool( "SizePrefixDisabled", sizePrefixDisabled );
+    }
+    AMQ_CATCH_NOTHROW( exceptions::ActiveMQException )
+    AMQ_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::beforeMarshal( WireFormat* wireFormat AMQCPP_UNUSED )
+    throw ( decaf::io::IOException ) {
+
+    try{
+
+        marshalledProperties.clear();
+        if( !properties.isEmpty() )
+        {
+            marshal::PrimitiveMapMarshaller::marshal(
+                &properties, marshalledProperties );
+        }
+    }
+    AMQ_CATCH_RETHROW( decaf::io::IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+    AMQ_CATCHALL_THROW( decaf::io::IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void WireFormatInfo::afterUnmarshal( WireFormat* wireFormat AMQCPP_UNUSED )
+    throw ( decaf::io::IOException ) {
+
+    try{
+
+        marshal::PrimitiveMapMarshaller::unmarshal(
+            &properties, marshalledProperties );
+    }
+    AMQ_CATCH_RETHROW( decaf::io::IOException )
+    AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
+    AMQ_CATCHALL_THROW( decaf::io::IOException )
+}

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,260 @@
+/**
+ * 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_COMMANDS_WIREFORMATINFO_H_
+#define _ACTIVEMQ_COMMANDS_WIREFORMATINFO_H_
+
+#include <activemq/util/Config.h>
+#include <activemq/commands/BaseCommand.h>
+#include <activemq/transport/Command.h>
+#include <activemq/util/PrimitiveMap.h>
+#include <activemq/exceptions/ActiveMQException.h>
+
+#include <vector>
+
+namespace activemq{
+namespace commands{
+
+    class AMQCPP_API WireFormatInfo : public BaseCommand<transport::Command> {
+    public:
+
+        const static unsigned char ID_WIREFORMATINFO = 1;
+
+    public:
+
+        WireFormatInfo();
+
+        virtual ~WireFormatInfo();
+
+        /**
+         * Get the unique identifier that this object and its own
+         * Marshaller share.
+         * @returns new DataStructure type copy.
+         */
+        virtual unsigned char getDataStructureType() const;
+
+        /**
+         * Clone this obbject and return a new instance that the
+         * caller now owns, this will be an exact copy of this one
+         * @returns new copy of this object.
+         */
+        virtual DataStructure* cloneDataStructure() const;
+
+        /**
+         * Copy the contents of the passed object into this objects
+         * members, overwriting any existing data.
+         * @return src - Source Object
+         */
+        virtual void copyDataStructure( const DataStructure* src );
+
+        /**
+         * Returns a string containing the information for this DataStructure
+         * such as its type and value of its elements.
+         * @return formatted string useful for debugging.
+         */
+        virtual std::string toString() const;
+        /**
+         * Compares the DataStructure passed in to this one, and returns if
+         * they are equivalent.  Equivalent here means that they are of the
+         * same type, and that each element of the objects are the same.
+         * @returns true if DataStructure's are Equal.
+         */
+        virtual bool equals( const DataStructure* value ) const;
+
+        /**
+         * Indicates that this command is aware of Marshalling, and needs
+         * to have its Marshalling methods invoked.
+         * @returns boolean indicating desire to be in marshalling stages
+         */
+        virtual bool isMarshalAware() const {
+            return true;
+        }
+
+        /**
+         * Get the current Wireformat Version
+         * @return int that identifies the version
+         */
+        int getVersion() const {
+            return version;
+        }
+
+        /**
+         * Set the current Wireformat Version
+         * @param version - int that identifies the version
+         */
+        void setVersion( int version ) {
+            this->version = version;
+        }
+
+        /**
+         * Checks if the stackTraceEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isStackTraceEnabled() const;
+
+        /**
+         * Sets if the stackTraceEnabled flag is on
+         * @param stackTraceEnabled - ture to turn flag is on
+         */
+        void setStackTraceEnabled( bool stackTraceEnabled );
+
+        /**
+         * Checks if the tcpNoDelayEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isTcpNoDelayEnabled() const;
+
+        /**
+         * Sets if the tcpNoDelayEnabled flag is on
+         * @param tcpNoDelayEnabled - ture to turn flag is on
+         */
+        void setTcpNoDelayEnabled( bool tcpNoDelayEnabled );
+
+        /**
+         * Checks if the cacheEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isCacheEnabled() const;
+
+        /**
+         * Sets if the cacheEnabled flag is on
+         * @param cacheEnabled - ture to turn flag is on
+         */
+        void setCacheEnabled( bool cacheEnabled );
+
+        /**
+         * Checks if the tightEncodingEnabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isTightEncodingEnabled() const;
+
+        /**
+         * Sets if the tightEncodingEnabled flag is on
+         * @param tightEncodingEnabled - ture to turn flag is on
+         */
+        void setTightEncodingEnabled( bool tightEncodingEnabled );
+
+        /**
+         * Checks if the sizePrefixDisabled flag is on
+         * @return true if the flag is on.
+         */
+        bool isSizePrefixDisabled() const;
+
+        /**
+         * Sets if the sizePrefixDisabled flag is on
+         * @param sizePrefixDisabled - ture to turn flag is on
+         */
+        void setSizePrefixDisabled( bool sizePrefixDisabled );
+
+        /**
+         * Get the Magic field
+         * @return const reference to a std::vector<char>
+         */
+        const std::vector<unsigned char>& getMagic() const {
+            return magic;
+        }
+
+        /**
+         * Sets the value of the magic field
+         * @param magic - const std::vector<char>
+         */
+        void setMagic( const std::vector<unsigned char>& magic ) {
+            this->magic = magic;
+        }
+
+        /**
+         * Get the marshalledProperties field
+         * @return const reference to a std::vector<char>
+         */
+        const std::vector<unsigned char>& getMarshalledProperties() const {
+            return marshalledProperties;
+        }
+
+        /**
+         * Sets the value of the marshalledProperties field
+         * @param magic - const std::vector<char>
+         */
+        void setMarshalledProperties( const std::vector<unsigned char>& marshalledProperties ) {
+            this->marshalledProperties = marshalledProperties;
+        }
+
+        /**
+         * Gets the Properties for this Command
+         * @param reference to a PrimitiveMap
+         * @throws cms::CMSException
+         */
+        virtual const util::PrimitiveMap& getProperties() const {
+            return properties;
+        }
+        virtual util::PrimitiveMap& getProperties() {
+            return properties;
+        }
+
+        /**
+         * Sets the Properties for this Command
+         * @param map - PrimtiveMap to copy
+         */
+        virtual void setProperties( const util::PrimitiveMap& map ) {
+            this->properties.copy( map );
+        }
+
+        /**
+         * Determines if we think this is a Valid WireFormatInfo command
+         * @returns true if its valid.
+         */
+        bool isValid() const;
+
+    public:
+
+        /**
+         * Handles the marshalling of the objects properties into the
+         * internal byte array before the object is marshalled to the
+         * wire
+         * @param wireFormat - the wireformatting controller
+         */
+        virtual void beforeMarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED )
+            throw ( decaf::io::IOException );
+
+        /**
+         * Called after unmarshaling is started to cleanup the object being
+         * unmarshaled.
+         * @param wireFormat - the wireformat object to control unmarshaling
+         */
+        virtual void afterUnmarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED )
+            throw ( decaf::io::IOException );
+
+    private:
+
+        std::vector<unsigned char> magic;
+        std::vector<unsigned char> marshalledProperties;
+
+        /**
+         * WireFormatInfo Properties, unmarshalled from the marshalled
+         * properties on use.
+         */
+        util::PrimitiveMap properties;
+
+        /**
+         * OpenWire Protocal Version
+         */
+        int version;
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_WIREFORMATINFO_H_*/

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/WireFormatInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,167 @@
+/*
+ * 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 <activemq/commands/XATransactionId.h>
+#include <activemq/exceptions/ActiveMQException.h>
+#include <decaf/lang/exceptions/NullPointerException.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::exceptions;
+using namespace activemq::commands;
+using namespace decaf::lang::exceptions;
+
+/*
+ *
+ *  Command and marshaling code for OpenWire format for XATransactionId
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+XATransactionId::XATransactionId()
+{
+    this->formatId = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+XATransactionId::~XATransactionId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+XATransactionId* XATransactionId::cloneDataStructure() const {
+    XATransactionId* xATransactionId = new XATransactionId();
+
+    // Copy the data from the base class or classes
+    xATransactionId->copyDataStructure( this );
+
+    return xATransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void XATransactionId::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    TransactionId::copyDataStructure( src );
+
+    const XATransactionId* srcPtr = dynamic_cast<const XATransactionId*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "XATransactionId::copyDataStructure - src is NULL or invalid" );
+    }
+    this->setFormatId( srcPtr->getFormatId() );
+    this->setGlobalTransactionId( srcPtr->getGlobalTransactionId() );
+    this->setBranchQualifier( srcPtr->getBranchQualifier() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char XATransactionId::getDataStructureType() const {
+    return XATransactionId::ID_XATRANSACTIONID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string XATransactionId::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = XATransactionId" << std::endl;
+    stream << " Value of XATransactionId::ID_XATRANSACTIONID = 112" << std::endl;
+    stream << " Value of FormatId = " << this->getFormatId() << std::endl;
+    for( size_t iglobalTransactionId = 0; iglobalTransactionId < this->getGlobalTransactionId().size(); ++iglobalTransactionId ) {
+        stream << " Value of GlobalTransactionId[" << iglobalTransactionId << "] = " << this->getGlobalTransactionId()[iglobalTransactionId] << std::endl;
+    }
+    for( size_t ibranchQualifier = 0; ibranchQualifier < this->getBranchQualifier().size(); ++ibranchQualifier ) {
+        stream << " Value of BranchQualifier[" << ibranchQualifier << "] = " << this->getBranchQualifier()[ibranchQualifier] << std::endl;
+    }
+    stream << TransactionId::toString();
+    stream << "End Class = XATransactionId" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool XATransactionId::equals( const DataStructure* value ) const {
+    const XATransactionId* valuePtr = dynamic_cast<const XATransactionId*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getFormatId() != valuePtr->getFormatId() ) {
+        return false;
+    }
+    for( size_t iglobalTransactionId = 0; iglobalTransactionId < this->getGlobalTransactionId().size(); ++iglobalTransactionId ) {
+        if( this->getGlobalTransactionId()[iglobalTransactionId] != valuePtr->getGlobalTransactionId()[iglobalTransactionId] ) {
+            return false;
+        }
+    }
+    for( size_t ibranchQualifier = 0; ibranchQualifier < this->getBranchQualifier().size(); ++ibranchQualifier ) {
+        if( this->getBranchQualifier()[ibranchQualifier] != valuePtr->getBranchQualifier()[ibranchQualifier] ) {
+            return false;
+        }
+    }
+    if( !TransactionId::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int XATransactionId::getFormatId() const {
+    return formatId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void XATransactionId::setFormatId(int formatId ) {
+    this->formatId = formatId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<unsigned char>& XATransactionId::getGlobalTransactionId() const {
+    return globalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<unsigned char>& XATransactionId::getGlobalTransactionId() {
+    return globalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void XATransactionId::setGlobalTransactionId(const std::vector<unsigned char>& globalTransactionId ) {
+    this->globalTransactionId = globalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<unsigned char>& XATransactionId::getBranchQualifier() const {
+    return branchQualifier;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<unsigned char>& XATransactionId::getBranchQualifier() {
+    return branchQualifier;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void XATransactionId::setBranchQualifier(const std::vector<unsigned char>& branchQualifier ) {
+    this->branchQualifier = branchQualifier;
+}
+

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,113 @@
+/*
+ * 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_COMMANDS_XATRANSACTIONID_H_
+#define _ACTIVEMQ_COMMANDS_XATRANSACTIONID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/util/Config.h>
+#include <activemq/commands/TransactionId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for XATransactionId
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class AMQCPP_API XATransactionId : public TransactionId
+    {
+    protected:
+
+        int formatId;
+        std::vector<unsigned char> globalTransactionId;
+        std::vector<unsigned char> branchQualifier;
+
+    public:
+
+        const static unsigned char ID_XATRANSACTIONID = 112;
+
+    public:
+
+        XATransactionId();
+        virtual ~XATransactionId();
+
+        /**
+         * Get the unique identifier that this object and its own
+         * Marshaller share.
+         * @returns new DataStructure type copy.
+         */
+        virtual unsigned char getDataStructureType() const;
+
+        /**
+         * Clone this object and return a new instance that the
+         * caller now owns, this will be an exact copy of this one
+         * @returns new copy of this object.
+         */
+        virtual XATransactionId* cloneDataStructure() const;
+
+        /**
+         * Copy the contents of the passed object into this object's
+         * members, overwriting any existing data.
+         * @param src - Source Object
+         */
+        virtual void copyDataStructure( const DataStructure* src );
+
+        /**
+         * Returns a string containing the information for this DataStructure
+         * such as its type and value of its elements.
+         * @return formatted string useful for debugging.
+         */
+        virtual std::string toString() const;
+
+        /**
+         * Compares the DataStructure passed in to this one, and returns if
+         * they are equivalent.  Equivalent here means that they are of the
+         * same type, and that each element of the objects are the same.
+         * @returns true if DataStructure's are Equal.
+         */
+        virtual bool equals( const DataStructure* value ) const;
+
+        virtual int getFormatId() const;
+        virtual void setFormatId( int formatId );
+
+        virtual const std::vector<unsigned char>& getGlobalTransactionId() const;
+        virtual std::vector<unsigned char>& getGlobalTransactionId();
+        virtual void setGlobalTransactionId( const std::vector<unsigned char>& globalTransactionId );
+
+        virtual const std::vector<unsigned char>& getBranchQualifier() const;
+        virtual std::vector<unsigned char>& getBranchQualifier();
+        virtual void setBranchQualifier( const std::vector<unsigned char>& branchQualifier );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_XATRANSACTIONID_H_*/
+

Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/XATransactionId.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/srcmakefile.mk
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/srcmakefile.mk?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/srcmakefile.mk (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/srcmakefile.mk Sun Jan 11 08:36:02 2009
@@ -0,0 +1,146 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+# 
+# http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+
+cc_sources += \
+    activemq/commands/ActiveMQBlobMessage.cpp \
+    activemq/commands/ActiveMQBytesMessage.cpp \
+    activemq/commands/ActiveMQDestination.cpp \
+    activemq/commands/ActiveMQMapMessage.cpp \
+    activemq/commands/ActiveMQMessage.cpp \
+    activemq/commands/ActiveMQObjectMessage.cpp \
+    activemq/commands/ActiveMQQueue.cpp \
+    activemq/commands/ActiveMQStreamMessage.cpp \
+    activemq/commands/ActiveMQTempDestination.cpp \
+    activemq/commands/ActiveMQTempQueue.cpp \
+    activemq/commands/ActiveMQTempTopic.cpp \
+    activemq/commands/ActiveMQTextMessage.cpp \
+    activemq/commands/ActiveMQTopic.cpp \
+    activemq/commands/BrokerId.cpp \
+    activemq/commands/BrokerInfo.cpp \
+    activemq/commands/ConnectionControl.cpp \
+    activemq/commands/ConnectionError.cpp \
+    activemq/commands/ConnectionId.cpp \
+    activemq/commands/ConnectionInfo.cpp \
+    activemq/commands/ConsumerControl.cpp \
+    activemq/commands/ConsumerId.cpp \
+    activemq/commands/ConsumerInfo.cpp \
+    activemq/commands/ControlCommand.cpp \
+    activemq/commands/DataArrayResponse.cpp \
+    activemq/commands/DataResponse.cpp \
+    activemq/commands/DestinationInfo.cpp \
+    activemq/commands/DiscoveryEvent.cpp \
+    activemq/commands/ExceptionResponse.cpp \
+    activemq/commands/FlushCommand.cpp \
+    activemq/commands/IntegerResponse.cpp \
+    activemq/commands/JournalQueueAck.cpp \
+    activemq/commands/JournalTopicAck.cpp \
+    activemq/commands/JournalTrace.cpp \
+    activemq/commands/JournalTransaction.cpp \
+    activemq/commands/KeepAliveInfo.cpp \
+    activemq/commands/LastPartialCommand.cpp \
+    activemq/commands/LocalTransactionId.cpp \
+    activemq/commands/Message.cpp \
+    activemq/commands/MessageAck.cpp \
+    activemq/commands/MessageDispatch.cpp \
+    activemq/commands/MessageDispatchNotification.cpp \
+    activemq/commands/MessageId.cpp \
+    activemq/commands/MessagePull.cpp \
+    activemq/commands/NetworkBridgeFilter.cpp \
+    activemq/commands/PartialCommand.cpp \
+    activemq/commands/ProducerAck.cpp \
+    activemq/commands/ProducerId.cpp \
+    activemq/commands/ProducerInfo.cpp \
+    activemq/commands/RemoveInfo.cpp \
+    activemq/commands/RemoveSubscriptionInfo.cpp \
+    activemq/commands/ReplayCommand.cpp \
+    activemq/commands/Response.cpp \
+    activemq/commands/SessionId.cpp \
+    activemq/commands/SessionInfo.cpp \
+    activemq/commands/ShutdownInfo.cpp \
+    activemq/commands/SubscriptionInfo.cpp \
+    activemq/commands/TransactionId.cpp \
+    activemq/commands/TransactionInfo.cpp \
+    activemq/commands/WireFormatInfo.cpp \
+    activemq/commands/XATransactionId.cpp
+
+h_sources += \
+    activemq/commands/ActiveMQBlobMessage.h \
+    activemq/commands/ActiveMQBytesMessage.h \
+    activemq/commands/ActiveMQDestination.h \
+    activemq/commands/ActiveMQMapMessage.h \
+    activemq/commands/ActiveMQMessage.h \
+    activemq/commands/ActiveMQMessageBase.h \
+    activemq/commands/ActiveMQObjectMessage.h \
+    activemq/commands/ActiveMQQueue.h \
+    activemq/commands/ActiveMQStreamMessage.h \
+    activemq/commands/ActiveMQTempDestination.h \
+    activemq/commands/ActiveMQTempQueue.h \
+    activemq/commands/ActiveMQTempTopic.h \
+    activemq/commands/ActiveMQTextMessage.h \
+    activemq/commands/ActiveMQTopic.h \
+    activemq/commands/BaseCommand.h \
+    activemq/commands/BaseDataStructure.h \
+    activemq/commands/BooleanExpression.h \
+    activemq/commands/BrokerError.h \
+    activemq/commands/BrokerId.h \
+    activemq/commands/BrokerInfo.h \
+    activemq/commands/ConnectionControl.h \
+    activemq/commands/ConnectionError.h \
+    activemq/commands/ConnectionId.h \
+    activemq/commands/ConnectionInfo.h \
+    activemq/commands/ConsumerControl.h \
+    activemq/commands/ConsumerId.h \
+    activemq/commands/ConsumerInfo.h \
+    activemq/commands/ControlCommand.h \
+    activemq/commands/DataArrayResponse.h \
+    activemq/commands/DataResponse.h \
+    activemq/commands/DataStructure.h \
+    activemq/commands/DestinationInfo.h \
+    activemq/commands/DiscoveryEvent.h \
+    activemq/commands/ExceptionResponse.h \
+    activemq/commands/FlushCommand.h \
+    activemq/commands/IntegerResponse.h \
+    activemq/commands/JournalQueueAck.h \
+    activemq/commands/JournalTopicAck.h \
+    activemq/commands/JournalTrace.h \
+    activemq/commands/JournalTransaction.h \
+    activemq/commands/KeepAliveInfo.h \
+    activemq/commands/LastPartialCommand.h \
+    activemq/commands/LocalTransactionId.h \
+    activemq/commands/Message.h \
+    activemq/commands/MessageAck.h \
+    activemq/commands/MessageDispatch.h \
+    activemq/commands/MessageDispatchNotification.h \
+    activemq/commands/MessageId.h \
+    activemq/commands/MessagePull.h \
+    activemq/commands/NetworkBridgeFilter.h \
+    activemq/commands/PartialCommand.h \
+    activemq/commands/ProducerAck.h \
+    activemq/commands/ProducerId.h \
+    activemq/commands/ProducerInfo.h \
+    activemq/commands/RemoveInfo.h \
+    activemq/commands/RemoveSubscriptionInfo.h \
+    activemq/commands/ReplayCommand.h \
+    activemq/commands/Response.h \
+    activemq/commands/SessionId.h \
+    activemq/commands/SessionInfo.h \
+    activemq/commands/ShutdownInfo.h \
+    activemq/commands/SubscriptionInfo.h \
+    activemq/commands/TransactionId.h \
+    activemq/commands/TransactionInfo.h \
+    activemq/commands/WireFormatInfo.h \
+    activemq/commands/XATransactionId.h



Mime
View raw message