svn commit: r733487 [8/10] - /activemq/activemq-cpp/trunk/src/main/activemq/commands/

[ta...@apache.org]

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,170 @@
+/*
+ * 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/MessageId.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 MessageId
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageId::MessageId()
+{
+    this->producerId = NULL;
+    this->producerSequenceId = 0;
+    this->brokerSequenceId = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId::~MessageId()
+{
+    delete this->producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageId::cloneDataStructure() const {
+    MessageId* messageId = new MessageId();
+
+    // Copy the data from the base class or classes
+    messageId->copyDataStructure( this );
+
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseDataStructure::copyDataStructure( src );
+
+    const MessageId* srcPtr = dynamic_cast<const MessageId*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "MessageId::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getProducerId() != NULL ) {
+        this->setProducerId(
+            dynamic_cast<ProducerId*>(
+                srcPtr->getProducerId()->cloneDataStructure() ) );
+    }
+    this->setProducerSequenceId( srcPtr->getProducerSequenceId() );
+    this->setBrokerSequenceId( srcPtr->getBrokerSequenceId() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageId::getDataStructureType() const {
+    return MessageId::ID_MESSAGEID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string MessageId::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = MessageId" << std::endl;
+    stream << " Value of MessageId::ID_MESSAGEID = 110" << std::endl;
+    stream << " Value of ProducerId is Below:" << std::endl;
+    if( this->getProducerId() != NULL ) {
+        stream << this->getProducerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of ProducerSequenceId = " << this->getProducerSequenceId() << std::endl;
+    stream << " Value of BrokerSequenceId = " << this->getBrokerSequenceId() << std::endl;
+    stream << BaseDataStructure::toString();
+    stream << "End Class = MessageId" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool MessageId::equals( const DataStructure* value ) const {
+    const MessageId* valuePtr = dynamic_cast<const MessageId*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getProducerId() != NULL ) {
+        if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getProducerId() != NULL ) {
+        return false;
+    }
+    if( this->getProducerSequenceId() != valuePtr->getProducerSequenceId() ) {
+        return false;
+    }
+    if( this->getBrokerSequenceId() != valuePtr->getBrokerSequenceId() ) {
+        return false;
+    }
+    if( !BaseDataStructure::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* MessageId::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* MessageId::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageId::getProducerSequenceId() const {
+    return producerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setProducerSequenceId(long long producerSequenceId ) {
+    this->producerSequenceId = producerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageId::getBrokerSequenceId() const {
+    return brokerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setBrokerSequenceId(long long brokerSequenceId ) {
+    this->brokerSequenceId = brokerSequenceId;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.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_MESSAGEID_H_
+#define _ACTIVEMQ_COMMANDS_MESSAGEID_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 <activemq/commands/ProducerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for MessageId
+     *
+     *
+     *  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 MessageId : public BaseDataStructure
+    {
+    protected:
+
+        ProducerId* producerId;
+        long long producerSequenceId;
+        long long brokerSequenceId;
+
+    public:
+
+        const static unsigned char ID_MESSAGEID = 110;
+
+    public:
+
+        MessageId();
+        virtual ~MessageId();
+
+        /**
+         * 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 MessageId* 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 ProducerId* getProducerId() const;
+        virtual ProducerId* getProducerId();
+        virtual void setProducerId( ProducerId* producerId );
+
+        virtual long long getProducerSequenceId() const;
+        virtual void setProducerSequenceId( long long producerSequenceId );
+
+        virtual long long getBrokerSequenceId() const;
+        virtual void setBrokerSequenceId( long long brokerSequenceId );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_MESSAGEID_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,245 @@
+/*
+ * 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/MessagePull.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 MessagePull
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessagePull::MessagePull()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->timeout = 0;
+    this->correlationId = "";
+    this->messageId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessagePull::~MessagePull()
+{
+    delete this->consumerId;
+    delete this->destination;
+    delete this->messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessagePull* MessagePull::cloneDataStructure() const {
+    MessagePull* messagePull = new MessagePull();
+
+    // Copy the data from the base class or classes
+    messagePull->copyDataStructure( this );
+
+    return messagePull;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const MessagePull* srcPtr = dynamic_cast<const MessagePull*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "MessagePull::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getConsumerId() != NULL ) {
+        this->setConsumerId(
+            dynamic_cast<ConsumerId*>(
+                srcPtr->getConsumerId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getDestination() != NULL ) {
+        this->setDestination(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getDestination()->cloneDataStructure() ) );
+    }
+    this->setTimeout( srcPtr->getTimeout() );
+    this->setCorrelationId( srcPtr->getCorrelationId() );
+    if( srcPtr->getMessageId() != NULL ) {
+        this->setMessageId(
+            dynamic_cast<MessageId*>(
+                srcPtr->getMessageId()->cloneDataStructure() ) );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessagePull::getDataStructureType() const {
+    return MessagePull::ID_MESSAGEPULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string MessagePull::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = MessagePull" << std::endl;
+    stream << " Value of MessagePull::ID_MESSAGEPULL = 20" << 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 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 Timeout = " << this->getTimeout() << std::endl;
+    stream << " Value of CorrelationId = " << this->getCorrelationId() << std::endl;
+    stream << " Value of MessageId is Below:" << std::endl;
+    if( this->getMessageId() != NULL ) {
+        stream << this->getMessageId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = MessagePull" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool MessagePull::equals( const DataStructure* value ) const {
+    const MessagePull* valuePtr = dynamic_cast<const MessagePull*>( 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->getDestination() != NULL ) {
+        if( !this->getDestination()->equals( valuePtr->getDestination() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getDestination() != NULL ) {
+        return false;
+    }
+    if( this->getTimeout() != valuePtr->getTimeout() ) {
+        return false;
+    }
+    if( this->getCorrelationId() != valuePtr->getCorrelationId() ) {
+        return false;
+    }
+    if( this->getMessageId() != NULL ) {
+        if( !this->getMessageId()->equals( valuePtr->getMessageId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getMessageId() != NULL ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessagePull::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessagePull::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessagePull::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessagePull::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessagePull::getTimeout() const {
+    return timeout;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setTimeout(long long timeout ) {
+    this->timeout = timeout;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& MessagePull::getCorrelationId() const {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& MessagePull::getCorrelationId() {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setCorrelationId(const std::string& correlationId ) {
+    this->correlationId = correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessagePull::getMessageId() const {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessagePull::getMessageId() {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setMessageId(MessageId* messageId ) {
+    this->messageId = messageId;
+}
+

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

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

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

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

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,109 @@
+/*
+ * 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_NETWORKBRIDGEFILTER_H_
+#define _ACTIVEMQ_COMMANDS_NETWORKBRIDGEFILTER_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 <activemq/commands/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for NetworkBridgeFilter
+     *
+     *
+     *  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 NetworkBridgeFilter : public BaseDataStructure
+    {
+    protected:
+
+        int networkTTL;
+        BrokerId* networkBrokerId;
+
+    public:
+
+        const static unsigned char ID_NETWORKBRIDGEFILTER = 91;
+
+    public:
+
+        NetworkBridgeFilter();
+        virtual ~NetworkBridgeFilter();
+
+        /**
+         * 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 NetworkBridgeFilter* 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 getNetworkTTL() const;
+        virtual void setNetworkTTL( int networkTTL );
+
+        virtual const BrokerId* getNetworkBrokerId() const;
+        virtual BrokerId* getNetworkBrokerId();
+        virtual void setNetworkBrokerId( BrokerId* networkBrokerId );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_NETWORKBRIDGEFILTER_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,143 @@
+/*
+ * 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/PartialCommand.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 PartialCommand
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+PartialCommand::PartialCommand()
+{
+    this->commandId = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+PartialCommand::~PartialCommand()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+PartialCommand* PartialCommand::cloneDataStructure() const {
+    PartialCommand* partialCommand = new PartialCommand();
+
+    // Copy the data from the base class or classes
+    partialCommand->copyDataStructure( this );
+
+    return partialCommand;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PartialCommand::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseDataStructure::copyDataStructure( src );
+
+    const PartialCommand* srcPtr = dynamic_cast<const PartialCommand*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "PartialCommand::copyDataStructure - src is NULL or invalid" );
+    }
+    this->setCommandId( srcPtr->getCommandId() );
+    this->setData( srcPtr->getData() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char PartialCommand::getDataStructureType() const {
+    return PartialCommand::ID_PARTIALCOMMAND;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string PartialCommand::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = PartialCommand" << std::endl;
+    stream << " Value of PartialCommand::ID_PARTIALCOMMAND = 60" << std::endl;
+    stream << " Value of CommandId = " << this->getCommandId() << std::endl;
+    for( size_t idata = 0; idata < this->getData().size(); ++idata ) {
+        stream << " Value of Data[" << idata << "] = " << this->getData()[idata] << std::endl;
+    }
+    stream << BaseDataStructure::toString();
+    stream << "End Class = PartialCommand" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool PartialCommand::equals( const DataStructure* value ) const {
+    const PartialCommand* valuePtr = dynamic_cast<const PartialCommand*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getCommandId() != valuePtr->getCommandId() ) {
+        return false;
+    }
+    for( size_t idata = 0; idata < this->getData().size(); ++idata ) {
+        if( this->getData()[idata] != valuePtr->getData()[idata] ) {
+            return false;
+        }
+    }
+    if( !BaseDataStructure::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int PartialCommand::getCommandId() const {
+    return commandId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PartialCommand::setCommandId(int commandId ) {
+    this->commandId = commandId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<unsigned char>& PartialCommand::getData() const {
+    return data;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<unsigned char>& PartialCommand::getData() {
+    return data;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PartialCommand::setData(const std::vector<unsigned char>& data ) {
+    this->data = data;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,108 @@
+/*
+ * 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_PARTIALCOMMAND_H_
+#define _ACTIVEMQ_COMMANDS_PARTIALCOMMAND_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 PartialCommand
+     *
+     *
+     *  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 PartialCommand : public BaseDataStructure
+    {
+    protected:
+
+        int commandId;
+        std::vector<unsigned char> data;
+
+    public:
+
+        const static unsigned char ID_PARTIALCOMMAND = 60;
+
+    public:
+
+        PartialCommand();
+        virtual ~PartialCommand();
+
+        /**
+         * 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 PartialCommand* 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 getCommandId() const;
+        virtual void setCommandId( int commandId );
+
+        virtual const std::vector<unsigned char>& getData() const;
+        virtual std::vector<unsigned char>& getData();
+        virtual void setData( const std::vector<unsigned char>& data );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_PARTIALCOMMAND_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,154 @@
+/*
+ * 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/ProducerAck.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 ProducerAck
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck::ProducerAck()
+{
+    this->producerId = NULL;
+    this->size = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck::~ProducerAck()
+{
+    delete this->producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerAck* ProducerAck::cloneDataStructure() const {
+    ProducerAck* producerAck = new ProducerAck();
+
+    // Copy the data from the base class or classes
+    producerAck->copyDataStructure( this );
+
+    return producerAck;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ProducerAck* srcPtr = dynamic_cast<const ProducerAck*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ProducerAck::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getProducerId() != NULL ) {
+        this->setProducerId(
+            dynamic_cast<ProducerId*>(
+                srcPtr->getProducerId()->cloneDataStructure() ) );
+    }
+    this->setSize( srcPtr->getSize() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ProducerAck::getDataStructureType() const {
+    return ProducerAck::ID_PRODUCERACK;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ProducerAck::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ProducerAck" << std::endl;
+    stream << " Value of ProducerAck::ID_PRODUCERACK = 19" << std::endl;
+    stream << " Value of ProducerId is Below:" << std::endl;
+    if( this->getProducerId() != NULL ) {
+        stream << this->getProducerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Size = " << this->getSize() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ProducerAck" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ProducerAck::equals( const DataStructure* value ) const {
+    const ProducerAck* valuePtr = dynamic_cast<const ProducerAck*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getProducerId() != NULL ) {
+        if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getProducerId() != NULL ) {
+        return false;
+    }
+    if( this->getSize() != valuePtr->getSize() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* ProducerAck::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* ProducerAck::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ProducerAck::getSize() const {
+    return size;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerAck::setSize(int size ) {
+    this->size = size;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,109 @@
+/*
+ * 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_PRODUCERACK_H_
+#define _ACTIVEMQ_COMMANDS_PRODUCERACK_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/ProducerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ProducerAck
+     *
+     *
+     *  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 ProducerAck : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ProducerId* producerId;
+        int size;
+
+    public:
+
+        const static unsigned char ID_PRODUCERACK = 19;
+
+    public:
+
+        ProducerAck();
+        virtual ~ProducerAck();
+
+        /**
+         * 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 ProducerAck* 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 ProducerId* getProducerId() const;
+        virtual ProducerId* getProducerId();
+        virtual void setProducerId( ProducerId* producerId );
+
+        virtual int getSize() const;
+        virtual void setSize( int size );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_PRODUCERACK_H_*/
+

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

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

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.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_PRODUCERID_H_
+#define _ACTIVEMQ_COMMANDS_PRODUCERID_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 ProducerId
+     *
+     *
+     *  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 ProducerId : public BaseDataStructure
+    {
+    protected:
+
+        std::string connectionId;
+        long long value;
+        long long sessionId;
+
+    public:
+
+        const static unsigned char ID_PRODUCERID = 123;
+
+    public:
+
+        ProducerId();
+        virtual ~ProducerId();
+
+        /**
+         * 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 ProducerId* 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 getValue() const;
+        virtual void setValue( long long value );
+
+        virtual long long getSessionId() const;
+        virtual void setSessionId( long long sessionId );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_PRODUCERID_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,249 @@
+/*
+ * 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/ProducerInfo.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 ProducerInfo
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ProducerInfo::ProducerInfo()
+{
+    this->producerId = NULL;
+    this->destination = NULL;
+    this->dispatchAsync = false;
+    this->windowSize = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerInfo::~ProducerInfo()
+{
+    delete this->producerId;
+    delete this->destination;
+    for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+        delete brokerPath[ibrokerPath];
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerInfo* ProducerInfo::cloneDataStructure() const {
+    ProducerInfo* producerInfo = new ProducerInfo();
+
+    // Copy the data from the base class or classes
+    producerInfo->copyDataStructure( this );
+
+    return producerInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const ProducerInfo* srcPtr = dynamic_cast<const ProducerInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "ProducerInfo::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getProducerId() != NULL ) {
+        this->setProducerId(
+            dynamic_cast<ProducerId*>(
+                srcPtr->getProducerId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getDestination() != NULL ) {
+        this->setDestination(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getDestination()->cloneDataStructure() ) );
+    }
+    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->setDispatchAsync( srcPtr->isDispatchAsync() );
+    this->setWindowSize( srcPtr->getWindowSize() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ProducerInfo::getDataStructureType() const {
+    return ProducerInfo::ID_PRODUCERINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string ProducerInfo::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = ProducerInfo" << std::endl;
+    stream << " Value of ProducerInfo::ID_PRODUCERINFO = 6" << std::endl;
+    stream << " Value of ProducerId is Below:" << std::endl;
+    if( this->getProducerId() != NULL ) {
+        stream << this->getProducerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << 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;
+    }
+    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 DispatchAsync = " << this->isDispatchAsync() << std::endl;
+    stream << " Value of WindowSize = " << this->getWindowSize() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = ProducerInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ProducerInfo::equals( const DataStructure* value ) const {
+    const ProducerInfo* valuePtr = dynamic_cast<const ProducerInfo*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getProducerId() != NULL ) {
+        if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getProducerId() != NULL ) {
+        return false;
+    }
+    if( this->getDestination() != NULL ) {
+        if( !this->getDestination()->equals( valuePtr->getDestination() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getDestination() != NULL ) {
+        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->isDispatchAsync() != valuePtr->isDispatchAsync() ) {
+        return false;
+    }
+    if( this->getWindowSize() != valuePtr->getWindowSize() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* ProducerInfo::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* ProducerInfo::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* ProducerInfo::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* ProducerInfo::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& ProducerInfo::getBrokerPath() const {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& ProducerInfo::getBrokerPath() {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setBrokerPath(const std::vector<BrokerId*>& brokerPath ) {
+    this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ProducerInfo::isDispatchAsync() const {
+    return dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setDispatchAsync(bool dispatchAsync ) {
+    this->dispatchAsync = dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ProducerInfo::getWindowSize() const {
+    return windowSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ProducerInfo::setWindowSize(int windowSize ) {
+    this->windowSize = windowSize;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.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_PRODUCERINFO_H_
+#define _ACTIVEMQ_COMMANDS_PRODUCERINFO_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/ProducerId.h>
+#include <activemq/commands/ActiveMQDestination.h>
+#include <activemq/commands/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for ProducerInfo
+     *
+     *
+     *  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 ProducerInfo : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ProducerId* producerId;
+        ActiveMQDestination* destination;
+        std::vector<BrokerId*> brokerPath;
+        bool dispatchAsync;
+        int windowSize;
+
+    public:
+
+        const static unsigned char ID_PRODUCERINFO = 6;
+
+    public:
+
+        ProducerInfo();
+        virtual ~ProducerInfo();
+
+        /**
+         * 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 ProducerInfo* 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 ProducerId* getProducerId() const;
+        virtual ProducerId* getProducerId();
+        virtual void setProducerId( ProducerId* producerId );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const std::vector<BrokerId*>& getBrokerPath() const;
+        virtual std::vector<BrokerId*>& getBrokerPath();
+        virtual void setBrokerPath( const std::vector<BrokerId*>& brokerPath );
+
+        virtual bool isDispatchAsync() const;
+        virtual void setDispatchAsync( bool dispatchAsync );
+
+        virtual int getWindowSize() const;
+        virtual void setWindowSize( int windowSize );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_PRODUCERINFO_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp 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.
+ */
+#include <activemq/commands/RemoveInfo.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 RemoveInfo
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+RemoveInfo::RemoveInfo()
+{
+    this->objectId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+RemoveInfo::~RemoveInfo()
+{
+    delete this->objectId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+RemoveInfo* RemoveInfo::cloneDataStructure() const {
+    RemoveInfo* removeInfo = new RemoveInfo();
+
+    // Copy the data from the base class or classes
+    removeInfo->copyDataStructure( this );
+
+    return removeInfo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void RemoveInfo::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const RemoveInfo* srcPtr = dynamic_cast<const RemoveInfo*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "RemoveInfo::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getObjectId() != NULL ) {
+        this->setObjectId(
+            dynamic_cast<DataStructure*>(
+                srcPtr->getObjectId()->cloneDataStructure() ) );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char RemoveInfo::getDataStructureType() const {
+    return RemoveInfo::ID_REMOVEINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string RemoveInfo::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = RemoveInfo" << std::endl;
+    stream << " Value of RemoveInfo::ID_REMOVEINFO = 12" << std::endl;
+    stream << " Value of ObjectId is Below:" << std::endl;
+    if( this->getObjectId() != NULL ) {
+        stream << this->getObjectId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = RemoveInfo" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool RemoveInfo::equals( const DataStructure* value ) const {
+    const RemoveInfo* valuePtr = dynamic_cast<const RemoveInfo*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getObjectId() != NULL ) {
+        if( !this->getObjectId()->equals( valuePtr->getObjectId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getObjectId() != NULL ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const DataStructure* RemoveInfo::getObjectId() const {
+    return objectId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* RemoveInfo::getObjectId() {
+    return objectId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void RemoveInfo::setObjectId(DataStructure* objectId ) {
+    this->objectId = objectId;
+}
+

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