activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r733487 [4/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/ConnectionError.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,173 @@
+/*
+ * 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/ConnectionError.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 ConnectionError
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionError::ConnectionError()
+{
+    this->exception = NULL;
+    this->connectionId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionError::~ConnectionError()
+{
+    delete this->exception;
+    delete this->connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionError* ConnectionError::cloneDataStructure() const {
+    ConnectionError* connectionError = new ConnectionError();
+
+    // Copy the data from the base class or classes
+    connectionError->copyDataStructure( this );
+
+    return connectionError;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionError::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ConnectionError* srcPtr = dynamic_cast<const ConnectionError*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConnectionError::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getException() != NULL ) {
+        this->setException(
+            dynamic_cast<BrokerError*>(
+                srcPtr->getException()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getConnectionId() != NULL ) {
+        this->setConnectionId(
+            dynamic_cast<ConnectionId*>(
+                srcPtr->getConnectionId()->cloneDataStructure() ) );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionError::getDataStructureType() const {
+    return ConnectionError::ID_CONNECTIONERROR;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConnectionError::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConnectionError" << std::endl;
+    stream << " Value of ConnectionError::ID_CONNECTIONERROR = 16" << std::endl;
+    stream << " Value of Exception is Below:" << std::endl;
+    if( this->getException() != NULL ) {
+        stream << this->getException()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << 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 << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ConnectionError" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionError::equals( const DataStructure* value ) const {
+    const ConnectionError* valuePtr = dynamic_cast<const ConnectionError*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getException() != NULL ) {
+        if( !this->getException()->equals( valuePtr->getException() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getException() != NULL ) {
+        return false;
+    }
+    if( this->getConnectionId() != NULL ) {
+        if( !this->getConnectionId()->equals( valuePtr->getConnectionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getConnectionId() != NULL ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const BrokerError* ConnectionError::getException() const {
+    return exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BrokerError* ConnectionError::getException() {
+    return exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionError::setException(BrokerError* exception ) {
+    this->exception = exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* ConnectionError::getConnectionId() const {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* ConnectionError::getConnectionId() {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionError::setConnectionId(ConnectionId* connectionId ) {
+    this->connectionId = connectionId;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionError.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,111 @@
+/*
+ * 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_CONNECTIONERROR_H_
+#define _ACTIVEMQ_COMMANDS_CONNECTIONERROR_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/BrokerError.h>
+#include <activemq/commands/ConnectionId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConnectionError
+     *
+     *
+     *  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 ConnectionError : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        BrokerError* exception;
+        ConnectionId* connectionId;
+
+    public:
+
+        const static unsigned char ID_CONNECTIONERROR = 16;
+
+    public:
+
+        ConnectionError();
+        virtual ~ConnectionError();
+
+        /**
+         * 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 ConnectionError* 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 BrokerError* getException() const;
+        virtual BrokerError* getException();
+        virtual void setException( BrokerError* exception );
+
+        virtual const ConnectionId* getConnectionId() const;
+        virtual ConnectionId* getConnectionId();
+        virtual void setConnectionId( ConnectionId* connectionId );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONNECTIONERROR_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,124 @@
+/*
+ * 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/ConnectionId.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 ConnectionId
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId::ConnectionId()
+{
+    this->value = "";
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId::~ConnectionId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* ConnectionId::cloneDataStructure() const {
+    ConnectionId* connectionId = new ConnectionId();
+
+    // Copy the data from the base class or classes
+    connectionId->copyDataStructure( this );
+
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionId::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseDataStructure::copyDataStructure( src );
+
+    const ConnectionId* srcPtr = dynamic_cast<const ConnectionId*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConnectionId::copyDataStructure - src is NULL or invalid" );
+    }
+    this->setValue( srcPtr->getValue() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionId::getDataStructureType() const {
+    return ConnectionId::ID_CONNECTIONID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConnectionId::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConnectionId" << std::endl;
+    stream << " Value of ConnectionId::ID_CONNECTIONID = 120" << std::endl;
+    stream << " Value of Value = " << this->getValue() << std::endl;
+    stream << BaseDataStructure::toString();
+    stream << "End Class = ConnectionId" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionId::equals( const DataStructure* value ) const {
+    const ConnectionId* valuePtr = dynamic_cast<const ConnectionId*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getValue() != valuePtr->getValue() ) {
+        return false;
+    }
+    if( !BaseDataStructure::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionId::getValue() const {
+    return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionId::getValue() {
+    return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionId::setValue(const std::string& value ) {
+    this->value = value;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionId.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,104 @@
+/*
+ * 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_CONNECTIONID_H_
+#define _ACTIVEMQ_COMMANDS_CONNECTIONID_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/BaseDataStructure.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConnectionId
+     *
+     *
+     *  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 ConnectionId : public BaseDataStructure
+    {
+    protected:
+
+        std::string value;
+
+    public:
+
+        const static unsigned char ID_CONNECTIONID = 120;
+
+    public:
+
+        ConnectionId();
+        virtual ~ConnectionId();
+
+        /**
+         * 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 ConnectionId* 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 std::string& getValue() const;
+        virtual std::string& getValue();
+        virtual void setValue( const std::string& value );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONNECTIONID_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,293 @@
+/*
+ * 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/ConnectionInfo.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 ConnectionInfo
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionInfo::ConnectionInfo()
+{
+    this->connectionId = NULL;
+    this->clientId = "";
+    this->password = "";
+    this->userName = "";
+    this->brokerMasterConnector = false;
+    this->manageable = false;
+    this->clientMaster = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionInfo::~ConnectionInfo()
+{
+    delete this->connectionId;
+    for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+        delete brokerPath[ibrokerPath];
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionInfo* ConnectionInfo::cloneDataStructure() const {
+    ConnectionInfo* connectionInfo = new ConnectionInfo();
+
+    // Copy the data from the base class or classes
+    connectionInfo->copyDataStructure( this );
+
+    return connectionInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ConnectionInfo* srcPtr = dynamic_cast<const ConnectionInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConnectionInfo::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getConnectionId() != NULL ) {
+        this->setConnectionId(
+            dynamic_cast<ConnectionId*>(
+                srcPtr->getConnectionId()->cloneDataStructure() ) );
+    }
+    this->setClientId( srcPtr->getClientId() );
+    this->setPassword( srcPtr->getPassword() );
+    this->setUserName( srcPtr->getUserName() );
+    for( size_t ibrokerPath = 0; ibrokerPath < srcPtr->getBrokerPath().size(); ++ibrokerPath ) {
+        if( srcPtr->getBrokerPath()[ibrokerPath] != NULL ) {
+            this->getBrokerPath().push_back(
+                dynamic_cast<BrokerId*>(
+                    srcPtr->getBrokerPath()[ibrokerPath]->cloneDataStructure() ) );
+        } else {
+            this->getBrokerPath().push_back( NULL );
+        }
+    }
+    this->setBrokerMasterConnector( srcPtr->isBrokerMasterConnector() );
+    this->setManageable( srcPtr->isManageable() );
+    this->setClientMaster( srcPtr->isClientMaster() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionInfo::getDataStructureType() const {
+    return ConnectionInfo::ID_CONNECTIONINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConnectionInfo::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConnectionInfo" << std::endl;
+    stream << " Value of ConnectionInfo::ID_CONNECTIONINFO = 3" << 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 ClientId = " << this->getClientId() << std::endl;
+    stream << " Value of Password = " << this->getPassword() << std::endl;
+    stream << " Value of UserName = " << this->getUserName() << std::endl;
+    for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) {
+        stream << " Value of BrokerPath[" << ibrokerPath << "] is Below:" << std::endl;
+        if( this->getBrokerPath()[ibrokerPath] != NULL ) {
+            stream << this->getBrokerPath()[ibrokerPath]->toString() << std::endl;
+        } else {
+            stream << "   Object is NULL" << std::endl;
+        }
+    }
+    stream << " Value of BrokerMasterConnector = " << this->isBrokerMasterConnector() << std::endl;
+    stream << " Value of Manageable = " << this->isManageable() << std::endl;
+    stream << " Value of ClientMaster = " << this->isClientMaster() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ConnectionInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::equals( const DataStructure* value ) const {
+    const ConnectionInfo* valuePtr = dynamic_cast<const ConnectionInfo*>( 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->getClientId() != valuePtr->getClientId() ) {
+        return false;
+    }
+    if( this->getPassword() != valuePtr->getPassword() ) {
+        return false;
+    }
+    if( this->getUserName() != valuePtr->getUserName() ) {
+        return false;
+    }
+    for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) {
+        if( this->getBrokerPath()[ibrokerPath] != NULL ) {
+            if( !this->getBrokerPath()[ibrokerPath]->equals( valuePtr->getBrokerPath()[ibrokerPath] ) ) {
+                return false;
+            }
+        } else if( valuePtr->getBrokerPath()[ibrokerPath] != NULL ) {
+            return false;
+        }
+    }
+    if( this->isBrokerMasterConnector() != valuePtr->isBrokerMasterConnector() ) {
+        return false;
+    }
+    if( this->isManageable() != valuePtr->isManageable() ) {
+        return false;
+    }
+    if( this->isClientMaster() != valuePtr->isClientMaster() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* ConnectionInfo::getConnectionId() const {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* ConnectionInfo::getConnectionId() {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setConnectionId(ConnectionId* connectionId ) {
+    this->connectionId = connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getClientId() const {
+    return clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getClientId() {
+    return clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setClientId(const std::string& clientId ) {
+    this->clientId = clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getPassword() const {
+    return password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getPassword() {
+    return password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setPassword(const std::string& password ) {
+    this->password = password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getUserName() const {
+    return userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getUserName() {
+    return userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setUserName(const std::string& userName ) {
+    this->userName = userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& ConnectionInfo::getBrokerPath() const {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& ConnectionInfo::getBrokerPath() {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setBrokerPath(const std::vector<BrokerId*>& brokerPath ) {
+    this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::isBrokerMasterConnector() const {
+    return brokerMasterConnector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setBrokerMasterConnector(bool brokerMasterConnector ) {
+    this->brokerMasterConnector = brokerMasterConnector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::isManageable() const {
+    return manageable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setManageable(bool manageable ) {
+    this->manageable = manageable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::isClientMaster() const {
+    return clientMaster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setClientMaster(bool clientMaster ) {
+    this->clientMaster = clientMaster;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConnectionInfo.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_COMMANDS_CONNECTIONINFO_H_
+#define _ACTIVEMQ_COMMANDS_CONNECTIONINFO_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/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConnectionInfo
+     *
+     *
+     *  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 ConnectionInfo : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ConnectionId* connectionId;
+        std::string clientId;
+        std::string password;
+        std::string userName;
+        std::vector<BrokerId*> brokerPath;
+        bool brokerMasterConnector;
+        bool manageable;
+        bool clientMaster;
+
+    public:
+
+        const static unsigned char ID_CONNECTIONINFO = 3;
+
+    public:
+
+        ConnectionInfo();
+        virtual ~ConnectionInfo();
+
+        /**
+         * 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 ConnectionInfo* 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 std::string& getClientId() const;
+        virtual std::string& getClientId();
+        virtual void setClientId( const std::string& clientId );
+
+        virtual const std::string& getPassword() const;
+        virtual std::string& getPassword();
+        virtual void setPassword( const std::string& password );
+
+        virtual const std::string& getUserName() const;
+        virtual std::string& getUserName();
+        virtual void setUserName( const std::string& userName );
+
+        virtual const std::vector<BrokerId*>& getBrokerPath() const;
+        virtual std::vector<BrokerId*>& getBrokerPath();
+        virtual void setBrokerPath( const std::vector<BrokerId*>& brokerPath );
+
+        virtual bool isBrokerMasterConnector() const;
+        virtual void setBrokerMasterConnector( bool brokerMasterConnector );
+
+        virtual bool isManageable() const;
+        virtual void setManageable( bool manageable );
+
+        virtual bool isClientMaster() const;
+        virtual void setClientMaster( bool clientMaster );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONNECTIONINFO_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,218 @@
+/*
+ * 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/ConsumerControl.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 ConsumerControl
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerControl::ConsumerControl()
+{
+    this->close = false;
+    this->consumerId = NULL;
+    this->prefetch = 0;
+    this->flush = false;
+    this->start = false;
+    this->stop = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerControl::~ConsumerControl()
+{
+    delete this->consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerControl* ConsumerControl::cloneDataStructure() const {
+    ConsumerControl* consumerControl = new ConsumerControl();
+
+    // Copy the data from the base class or classes
+    consumerControl->copyDataStructure( this );
+
+    return consumerControl;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ConsumerControl* srcPtr = dynamic_cast<const ConsumerControl*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConsumerControl::copyDataStructure - src is NULL or invalid" );
+    }
+    this->setClose( srcPtr->isClose() );
+    if( srcPtr->getConsumerId() != NULL ) {
+        this->setConsumerId(
+            dynamic_cast<ConsumerId*>(
+                srcPtr->getConsumerId()->cloneDataStructure() ) );
+    }
+    this->setPrefetch( srcPtr->getPrefetch() );
+    this->setFlush( srcPtr->isFlush() );
+    this->setStart( srcPtr->isStart() );
+    this->setStop( srcPtr->isStop() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerControl::getDataStructureType() const {
+    return ConsumerControl::ID_CONSUMERCONTROL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConsumerControl::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConsumerControl" << std::endl;
+    stream << " Value of ConsumerControl::ID_CONSUMERCONTROL = 17" << std::endl;
+    stream << " Value of Close = " << this->isClose() << std::endl;
+    stream << " Value of ConsumerId is Below:" << std::endl;
+    if( this->getConsumerId() != NULL ) {
+        stream << this->getConsumerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Prefetch = " << this->getPrefetch() << std::endl;
+    stream << " Value of Flush = " << this->isFlush() << std::endl;
+    stream << " Value of Start = " << this->isStart() << std::endl;
+    stream << " Value of Stop = " << this->isStop() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ConsumerControl" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::equals( const DataStructure* value ) const {
+    const ConsumerControl* valuePtr = dynamic_cast<const ConsumerControl*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->isClose() != valuePtr->isClose() ) {
+        return false;
+    }
+    if( this->getConsumerId() != NULL ) {
+        if( !this->getConsumerId()->equals( valuePtr->getConsumerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getConsumerId() != NULL ) {
+        return false;
+    }
+    if( this->getPrefetch() != valuePtr->getPrefetch() ) {
+        return false;
+    }
+    if( this->isFlush() != valuePtr->isFlush() ) {
+        return false;
+    }
+    if( this->isStart() != valuePtr->isStart() ) {
+        return false;
+    }
+    if( this->isStop() != valuePtr->isStop() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::isClose() const {
+    return close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setClose(bool close ) {
+    this->close = close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* ConsumerControl::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* ConsumerControl::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerControl::getPrefetch() const {
+    return prefetch;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setPrefetch(int prefetch ) {
+    this->prefetch = prefetch;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::isFlush() const {
+    return flush;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setFlush(bool flush ) {
+    this->flush = flush;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::isStart() const {
+    return start;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setStart(bool start ) {
+    this->start = start;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::isStop() const {
+    return stop;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setStop(bool stop ) {
+    this->stop = stop;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerControl.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,125 @@
+/*
+ * 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_CONSUMERCONTROL_H_
+#define _ACTIVEMQ_COMMANDS_CONSUMERCONTROL_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/ConsumerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConsumerControl
+     *
+     *
+     *  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 ConsumerControl : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        bool close;
+        ConsumerId* consumerId;
+        int prefetch;
+        bool flush;
+        bool start;
+        bool stop;
+
+    public:
+
+        const static unsigned char ID_CONSUMERCONTROL = 17;
+
+    public:
+
+        ConsumerControl();
+        virtual ~ConsumerControl();
+
+        /**
+         * 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 ConsumerControl* 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 bool isClose() const;
+        virtual void setClose( bool close );
+
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual int getPrefetch() const;
+        virtual void setPrefetch( int prefetch );
+
+        virtual bool isFlush() const;
+        virtual void setFlush( bool flush );
+
+        virtual bool isStart() const;
+        virtual void setStart( bool start );
+
+        virtual bool isStop() const;
+        virtual void setStop( bool stop );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONSUMERCONTROL_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,156 @@
+/*
+ * 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/ConsumerId.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 ConsumerId
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId::ConsumerId()
+{
+    this->connectionId = "";
+    this->sessionId = 0;
+    this->value = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId::~ConsumerId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* ConsumerId::cloneDataStructure() const {
+    ConsumerId* consumerId = new ConsumerId();
+
+    // Copy the data from the base class or classes
+    consumerId->copyDataStructure( this );
+
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseDataStructure::copyDataStructure( src );
+
+    const ConsumerId* srcPtr = dynamic_cast<const ConsumerId*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConsumerId::copyDataStructure - src is NULL or invalid" );
+    }
+    this->setConnectionId( srcPtr->getConnectionId() );
+    this->setSessionId( srcPtr->getSessionId() );
+    this->setValue( srcPtr->getValue() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerId::getDataStructureType() const {
+    return ConsumerId::ID_CONSUMERID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConsumerId::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConsumerId" << std::endl;
+    stream << " Value of ConsumerId::ID_CONSUMERID = 122" << std::endl;
+    stream << " Value of ConnectionId = " << this->getConnectionId() << std::endl;
+    stream << " Value of SessionId = " << this->getSessionId() << std::endl;
+    stream << " Value of Value = " << this->getValue() << std::endl;
+    stream << BaseDataStructure::toString();
+    stream << "End Class = ConsumerId" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerId::equals( const DataStructure* value ) const {
+    const ConsumerId* valuePtr = dynamic_cast<const ConsumerId*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getConnectionId() != valuePtr->getConnectionId() ) {
+        return false;
+    }
+    if( this->getSessionId() != valuePtr->getSessionId() ) {
+        return false;
+    }
+    if( this->getValue() != valuePtr->getValue() ) {
+        return false;
+    }
+    if( !BaseDataStructure::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerId::getConnectionId() const {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerId::getConnectionId() {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setConnectionId(const std::string& connectionId ) {
+    this->connectionId = connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long ConsumerId::getSessionId() const {
+    return sessionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setSessionId(long long sessionId ) {
+    this->sessionId = sessionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long ConsumerId::getValue() const {
+    return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setValue(long long value ) {
+    this->value = value;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerId.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_COMMANDS_CONSUMERID_H_
+#define _ACTIVEMQ_COMMANDS_CONSUMERID_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/BaseDataStructure.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConsumerId
+     *
+     *
+     *  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 ConsumerId : public BaseDataStructure
+    {
+    protected:
+
+        std::string connectionId;
+        long long sessionId;
+        long long value;
+
+    public:
+
+        const static unsigned char ID_CONSUMERID = 122;
+
+    public:
+
+        ConsumerId();
+        virtual ~ConsumerId();
+
+        /**
+         * 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 ConsumerId* 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 std::string& getConnectionId() const;
+        virtual std::string& getConnectionId();
+        virtual void setConnectionId( const std::string& connectionId );
+
+        virtual long long getSessionId() const;
+        virtual void setSessionId( long long sessionId );
+
+        virtual long long getValue() const;
+        virtual void setValue( long long value );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONSUMERID_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,470 @@
+/*
+ * 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/ConsumerInfo.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 ConsumerInfo
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerInfo::ConsumerInfo()
+{
+    this->consumerId = NULL;
+    this->browser = false;
+    this->destination = NULL;
+    this->prefetchSize = 0;
+    this->maximumPendingMessageLimit = 0;
+    this->dispatchAsync = false;
+    this->selector = "";
+    this->subscriptionName = "";
+    this->noLocal = false;
+    this->exclusive = false;
+    this->retroactive = false;
+    this->priority = 0;
+    this->additionalPredicate = NULL;
+    this->networkSubscription = false;
+    this->optimizedAcknowledge = false;
+    this->noRangeAcks = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerInfo::~ConsumerInfo()
+{
+    delete this->consumerId;
+    delete this->destination;
+    for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+        delete brokerPath[ibrokerPath];
+    }
+    delete this->additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerInfo* ConsumerInfo::cloneDataStructure() const {
+    ConsumerInfo* consumerInfo = new ConsumerInfo();
+
+    // Copy the data from the base class or classes
+    consumerInfo->copyDataStructure( this );
+
+    return consumerInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ConsumerInfo* srcPtr = dynamic_cast<const ConsumerInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ConsumerInfo::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getConsumerId() != NULL ) {
+        this->setConsumerId(
+            dynamic_cast<ConsumerId*>(
+                srcPtr->getConsumerId()->cloneDataStructure() ) );
+    }
+    this->setBrowser( srcPtr->isBrowser() );
+    if( srcPtr->getDestination() != NULL ) {
+        this->setDestination(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getDestination()->cloneDataStructure() ) );
+    }
+    this->setPrefetchSize( srcPtr->getPrefetchSize() );
+    this->setMaximumPendingMessageLimit( srcPtr->getMaximumPendingMessageLimit() );
+    this->setDispatchAsync( srcPtr->isDispatchAsync() );
+    this->setSelector( srcPtr->getSelector() );
+    this->setSubscriptionName( srcPtr->getSubscriptionName() );
+    this->setNoLocal( srcPtr->isNoLocal() );
+    this->setExclusive( srcPtr->isExclusive() );
+    this->setRetroactive( srcPtr->isRetroactive() );
+    this->setPriority( srcPtr->getPriority() );
+    for( size_t ibrokerPath = 0; ibrokerPath < srcPtr->getBrokerPath().size(); ++ibrokerPath ) {
+        if( srcPtr->getBrokerPath()[ibrokerPath] != NULL ) {
+            this->getBrokerPath().push_back(
+                dynamic_cast<BrokerId*>(
+                    srcPtr->getBrokerPath()[ibrokerPath]->cloneDataStructure() ) );
+        } else {
+            this->getBrokerPath().push_back( NULL );
+        }
+    }
+    if( srcPtr->getAdditionalPredicate() != NULL ) {
+        this->setAdditionalPredicate(
+            dynamic_cast<BooleanExpression*>(
+                srcPtr->getAdditionalPredicate()->cloneDataStructure() ) );
+    }
+    this->setNetworkSubscription( srcPtr->isNetworkSubscription() );
+    this->setOptimizedAcknowledge( srcPtr->isOptimizedAcknowledge() );
+    this->setNoRangeAcks( srcPtr->isNoRangeAcks() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerInfo::getDataStructureType() const {
+    return ConsumerInfo::ID_CONSUMERINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ConsumerInfo::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ConsumerInfo" << std::endl;
+    stream << " Value of ConsumerInfo::ID_CONSUMERINFO = 5" << std::endl;
+    stream << " Value of ConsumerId is Below:" << std::endl;
+    if( this->getConsumerId() != NULL ) {
+        stream << this->getConsumerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Browser = " << this->isBrowser() << std::endl;
+    stream << " Value of Destination is Below:" << std::endl;
+    if( this->getDestination() != NULL ) {
+        stream << this->getDestination()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of PrefetchSize = " << this->getPrefetchSize() << std::endl;
+    stream << " Value of MaximumPendingMessageLimit = " << this->getMaximumPendingMessageLimit() << std::endl;
+    stream << " Value of DispatchAsync = " << this->isDispatchAsync() << std::endl;
+    stream << " Value of Selector = " << this->getSelector() << std::endl;
+    stream << " Value of SubscriptionName = " << this->getSubscriptionName() << std::endl;
+    stream << " Value of NoLocal = " << this->isNoLocal() << std::endl;
+    stream << " Value of Exclusive = " << this->isExclusive() << std::endl;
+    stream << " Value of Retroactive = " << this->isRetroactive() << std::endl;
+    stream << " Value of Priority = " << (int)this->getPriority() << std::endl;
+    for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) {
+        stream << " Value of BrokerPath[" << ibrokerPath << "] is Below:" << std::endl;
+        if( this->getBrokerPath()[ibrokerPath] != NULL ) {
+            stream << this->getBrokerPath()[ibrokerPath]->toString() << std::endl;
+        } else {
+            stream << "   Object is NULL" << std::endl;
+        }
+    }
+    stream << " Value of AdditionalPredicate is Below:" << std::endl;
+    if( this->getAdditionalPredicate() != NULL ) {
+        stream << this->getAdditionalPredicate()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of NetworkSubscription = " << this->isNetworkSubscription() << std::endl;
+    stream << " Value of OptimizedAcknowledge = " << this->isOptimizedAcknowledge() << std::endl;
+    stream << " Value of NoRangeAcks = " << this->isNoRangeAcks() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ConsumerInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::equals( const DataStructure* value ) const {
+    const ConsumerInfo* valuePtr = dynamic_cast<const ConsumerInfo*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getConsumerId() != NULL ) {
+        if( !this->getConsumerId()->equals( valuePtr->getConsumerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getConsumerId() != NULL ) {
+        return false;
+    }
+    if( this->isBrowser() != valuePtr->isBrowser() ) {
+        return false;
+    }
+    if( this->getDestination() != NULL ) {
+        if( !this->getDestination()->equals( valuePtr->getDestination() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getDestination() != NULL ) {
+        return false;
+    }
+    if( this->getPrefetchSize() != valuePtr->getPrefetchSize() ) {
+        return false;
+    }
+    if( this->getMaximumPendingMessageLimit() != valuePtr->getMaximumPendingMessageLimit() ) {
+        return false;
+    }
+    if( this->isDispatchAsync() != valuePtr->isDispatchAsync() ) {
+        return false;
+    }
+    if( this->getSelector() != valuePtr->getSelector() ) {
+        return false;
+    }
+    if( this->getSubscriptionName() != valuePtr->getSubscriptionName() ) {
+        return false;
+    }
+    if( this->isNoLocal() != valuePtr->isNoLocal() ) {
+        return false;
+    }
+    if( this->isExclusive() != valuePtr->isExclusive() ) {
+        return false;
+    }
+    if( this->isRetroactive() != valuePtr->isRetroactive() ) {
+        return false;
+    }
+    if( this->getPriority() != valuePtr->getPriority() ) {
+        return false;
+    }
+    for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) {
+        if( this->getBrokerPath()[ibrokerPath] != NULL ) {
+            if( !this->getBrokerPath()[ibrokerPath]->equals( valuePtr->getBrokerPath()[ibrokerPath] ) ) {
+                return false;
+            }
+        } else if( valuePtr->getBrokerPath()[ibrokerPath] != NULL ) {
+            return false;
+        }
+    }
+    if( this->getAdditionalPredicate() != NULL ) {
+        if( !this->getAdditionalPredicate()->equals( valuePtr->getAdditionalPredicate() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getAdditionalPredicate() != NULL ) {
+        return false;
+    }
+    if( this->isNetworkSubscription() != valuePtr->isNetworkSubscription() ) {
+        return false;
+    }
+    if( this->isOptimizedAcknowledge() != valuePtr->isOptimizedAcknowledge() ) {
+        return false;
+    }
+    if( this->isNoRangeAcks() != valuePtr->isNoRangeAcks() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* ConsumerInfo::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* ConsumerInfo::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isBrowser() const {
+    return browser;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setBrowser(bool browser ) {
+    this->browser = browser;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* ConsumerInfo::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* ConsumerInfo::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerInfo::getPrefetchSize() const {
+    return prefetchSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setPrefetchSize(int prefetchSize ) {
+    this->prefetchSize = prefetchSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerInfo::getMaximumPendingMessageLimit() const {
+    return maximumPendingMessageLimit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit ) {
+    this->maximumPendingMessageLimit = maximumPendingMessageLimit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isDispatchAsync() const {
+    return dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setDispatchAsync(bool dispatchAsync ) {
+    this->dispatchAsync = dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerInfo::getSelector() const {
+    return selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerInfo::getSelector() {
+    return selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setSelector(const std::string& selector ) {
+    this->selector = selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerInfo::getSubscriptionName() const {
+    return subscriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerInfo::getSubscriptionName() {
+    return subscriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setSubscriptionName(const std::string& subscriptionName ) {
+    this->subscriptionName = subscriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isNoLocal() const {
+    return noLocal;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNoLocal(bool noLocal ) {
+    this->noLocal = noLocal;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isExclusive() const {
+    return exclusive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setExclusive(bool exclusive ) {
+    this->exclusive = exclusive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isRetroactive() const {
+    return retroactive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setRetroactive(bool retroactive ) {
+    this->retroactive = retroactive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerInfo::getPriority() const {
+    return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setPriority(unsigned char priority ) {
+    this->priority = priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& ConsumerInfo::getBrokerPath() const {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& ConsumerInfo::getBrokerPath() {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setBrokerPath(const std::vector<BrokerId*>& brokerPath ) {
+    this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const BooleanExpression* ConsumerInfo::getAdditionalPredicate() const {
+    return additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BooleanExpression* ConsumerInfo::getAdditionalPredicate() {
+    return additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setAdditionalPredicate(BooleanExpression* additionalPredicate ) {
+    this->additionalPredicate = additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isNetworkSubscription() const {
+    return networkSubscription;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNetworkSubscription(bool networkSubscription ) {
+    this->networkSubscription = networkSubscription;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isOptimizedAcknowledge() const {
+    return optimizedAcknowledge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setOptimizedAcknowledge(bool optimizedAcknowledge ) {
+    this->optimizedAcknowledge = optimizedAcknowledge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::isNoRangeAcks() const {
+    return noRangeAcks;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNoRangeAcks(bool noRangeAcks ) {
+    this->noRangeAcks = noRangeAcks;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ConsumerInfo.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,177 @@
+/*
+ * 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_CONSUMERINFO_H_
+#define _ACTIVEMQ_COMMANDS_CONSUMERINFO_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/ConsumerId.h>
+#include <activemq/commands/ActiveMQDestination.h>
+#include <activemq/commands/BrokerId.h>
+#include <activemq/commands/BooleanExpression.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ConsumerInfo
+     *
+     *
+     *  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 ConsumerInfo : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        bool browser;
+        ActiveMQDestination* destination;
+        int prefetchSize;
+        int maximumPendingMessageLimit;
+        bool dispatchAsync;
+        std::string selector;
+        std::string subscriptionName;
+        bool noLocal;
+        bool exclusive;
+        bool retroactive;
+        unsigned char priority;
+        std::vector<BrokerId*> brokerPath;
+        BooleanExpression* additionalPredicate;
+        bool networkSubscription;
+        bool optimizedAcknowledge;
+        bool noRangeAcks;
+
+    public:
+
+        const static unsigned char ID_CONSUMERINFO = 5;
+
+    public:
+
+        ConsumerInfo();
+        virtual ~ConsumerInfo();
+
+        /**
+         * 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 ConsumerInfo* 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 ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual bool isBrowser() const;
+        virtual void setBrowser( bool browser );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual int getPrefetchSize() const;
+        virtual void setPrefetchSize( int prefetchSize );
+
+        virtual int getMaximumPendingMessageLimit() const;
+        virtual void setMaximumPendingMessageLimit( int maximumPendingMessageLimit );
+
+        virtual bool isDispatchAsync() const;
+        virtual void setDispatchAsync( bool dispatchAsync );
+
+        virtual const std::string& getSelector() const;
+        virtual std::string& getSelector();
+        virtual void setSelector( const std::string& selector );
+
+        virtual const std::string& getSubscriptionName() const;
+        virtual std::string& getSubscriptionName();
+        virtual void setSubscriptionName( const std::string& subscriptionName );
+
+        virtual bool isNoLocal() const;
+        virtual void setNoLocal( bool noLocal );
+
+        virtual bool isExclusive() const;
+        virtual void setExclusive( bool exclusive );
+
+        virtual bool isRetroactive() const;
+        virtual void setRetroactive( bool retroactive );
+
+        virtual unsigned char getPriority() const;
+        virtual void setPriority( unsigned char priority );
+
+        virtual const std::vector<BrokerId*>& getBrokerPath() const;
+        virtual std::vector<BrokerId*>& getBrokerPath();
+        virtual void setBrokerPath( const std::vector<BrokerId*>& brokerPath );
+
+        virtual const BooleanExpression* getAdditionalPredicate() const;
+        virtual BooleanExpression* getAdditionalPredicate();
+        virtual void setAdditionalPredicate( BooleanExpression* additionalPredicate );
+
+        virtual bool isNetworkSubscription() const;
+        virtual void setNetworkSubscription( bool networkSubscription );
+
+        virtual bool isOptimizedAcknowledge() const;
+        virtual void setOptimizedAcknowledge( bool optimizedAcknowledge );
+
+        virtual bool isNoRangeAcks() const;
+        virtual void setNoRangeAcks( bool noRangeAcks );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_CONSUMERINFO_H_*/
+

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



Mime
View raw message