activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r733487 [7/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/Message.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,841 @@
+/*
+ * 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/Message.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 Message
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+Message::Message()
+{
+    this->producerId = NULL;
+    this->destination = NULL;
+    this->transactionId = NULL;
+    this->originalDestination = NULL;
+    this->messageId = NULL;
+    this->originalTransactionId = NULL;
+    this->groupID = "";
+    this->groupSequence = 0;
+    this->correlationId = "";
+    this->persistent = false;
+    this->expiration = 0;
+    this->priority = 0;
+    this->replyTo = NULL;
+    this->timestamp = 0;
+    this->type = "";
+    this->dataStructure = NULL;
+    this->targetConsumerId = NULL;
+    this->compressed = false;
+    this->redeliveryCounter = 0;
+    this->arrival = 0;
+    this->userID = "";
+    this->recievedByDFBridge = false;
+    this->droppable = false;
+    this->brokerInTime = 0;
+    this->brokerOutTime = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+Message::~Message()
+{
+    delete this->producerId;
+    delete this->destination;
+    delete this->transactionId;
+    delete this->originalDestination;
+    delete this->messageId;
+    delete this->originalTransactionId;
+    delete this->replyTo;
+    delete this->dataStructure;
+    delete this->targetConsumerId;
+    for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+        delete brokerPath[ibrokerPath];
+    }
+    for( size_t icluster = 0; icluster < cluster.size(); ++icluster ) {
+        delete cluster[icluster];
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+Message* Message::cloneDataStructure() const {
+    Message* message = new Message();
+
+    // Copy the data from the base class or classes
+    message->copyDataStructure( this );
+
+    return message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const Message* srcPtr = dynamic_cast<const Message*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "Message::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() ) );
+    }
+    if( srcPtr->getTransactionId() != NULL ) {
+        this->setTransactionId(
+            dynamic_cast<TransactionId*>(
+                srcPtr->getTransactionId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getOriginalDestination() != NULL ) {
+        this->setOriginalDestination(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getOriginalDestination()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getMessageId() != NULL ) {
+        this->setMessageId(
+            dynamic_cast<MessageId*>(
+                srcPtr->getMessageId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getOriginalTransactionId() != NULL ) {
+        this->setOriginalTransactionId(
+            dynamic_cast<TransactionId*>(
+                srcPtr->getOriginalTransactionId()->cloneDataStructure() ) );
+    }
+    this->setGroupID( srcPtr->getGroupID() );
+    this->setGroupSequence( srcPtr->getGroupSequence() );
+    this->setCorrelationId( srcPtr->getCorrelationId() );
+    this->setPersistent( srcPtr->isPersistent() );
+    this->setExpiration( srcPtr->getExpiration() );
+    this->setPriority( srcPtr->getPriority() );
+    if( srcPtr->getReplyTo() != NULL ) {
+        this->setReplyTo(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getReplyTo()->cloneDataStructure() ) );
+    }
+    this->setTimestamp( srcPtr->getTimestamp() );
+    this->setType( srcPtr->getType() );
+    this->setContent( srcPtr->getContent() );
+    this->setMarshalledProperties( srcPtr->getMarshalledProperties() );
+    if( srcPtr->getDataStructure() != NULL ) {
+        this->setDataStructure(
+            dynamic_cast<DataStructure*>(
+                srcPtr->getDataStructure()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getTargetConsumerId() != NULL ) {
+        this->setTargetConsumerId(
+            dynamic_cast<ConsumerId*>(
+                srcPtr->getTargetConsumerId()->cloneDataStructure() ) );
+    }
+    this->setCompressed( srcPtr->isCompressed() );
+    this->setRedeliveryCounter( srcPtr->getRedeliveryCounter() );
+    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->setArrival( srcPtr->getArrival() );
+    this->setUserID( srcPtr->getUserID() );
+    this->setRecievedByDFBridge( srcPtr->isRecievedByDFBridge() );
+    this->setDroppable( srcPtr->isDroppable() );
+    for( size_t icluster = 0; icluster < srcPtr->getCluster().size(); ++icluster ) {
+        if( srcPtr->getCluster()[icluster] != NULL ) {
+            this->getCluster().push_back(
+                dynamic_cast<BrokerId*>(
+                    srcPtr->getCluster()[icluster]->cloneDataStructure() ) );
+        } else {
+            this->getCluster().push_back( NULL );
+        }
+    }
+    this->setBrokerInTime( srcPtr->getBrokerInTime() );
+    this->setBrokerOutTime( srcPtr->getBrokerOutTime() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char Message::getDataStructureType() const {
+    return Message::ID_MESSAGE;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string Message::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = Message" << std::endl;
+    stream << " Value of Message::ID_MESSAGE = 0" << 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;
+    }
+    stream << " Value of TransactionId is Below:" << std::endl;
+    if( this->getTransactionId() != NULL ) {
+        stream << this->getTransactionId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of OriginalDestination is Below:" << std::endl;
+    if( this->getOriginalDestination() != NULL ) {
+        stream << this->getOriginalDestination()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << 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 << " Value of OriginalTransactionId is Below:" << std::endl;
+    if( this->getOriginalTransactionId() != NULL ) {
+        stream << this->getOriginalTransactionId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of GroupID = " << this->getGroupID() << std::endl;
+    stream << " Value of GroupSequence = " << this->getGroupSequence() << std::endl;
+    stream << " Value of CorrelationId = " << this->getCorrelationId() << std::endl;
+    stream << " Value of Persistent = " << this->isPersistent() << std::endl;
+    stream << " Value of Expiration = " << this->getExpiration() << std::endl;
+    stream << " Value of Priority = " << (int)this->getPriority() << std::endl;
+    stream << " Value of ReplyTo is Below:" << std::endl;
+    if( this->getReplyTo() != NULL ) {
+        stream << this->getReplyTo()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Timestamp = " << this->getTimestamp() << std::endl;
+    stream << " Value of Type = " << this->getType() << std::endl;
+    for( size_t icontent = 0; icontent < this->getContent().size(); ++icontent ) {
+        stream << " Value of Content[" << icontent << "] = " << this->getContent()[icontent] << std::endl;
+    }
+    for( size_t imarshalledProperties = 0; imarshalledProperties < this->getMarshalledProperties().size(); ++imarshalledProperties ) {
+        stream << " Value of MarshalledProperties[" << imarshalledProperties << "] = " << this->getMarshalledProperties()[imarshalledProperties] << std::endl;
+    }
+    stream << " Value of DataStructure is Below:" << std::endl;
+    if( this->getDataStructure() != NULL ) {
+        stream << this->getDataStructure()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of TargetConsumerId is Below:" << std::endl;
+    if( this->getTargetConsumerId() != NULL ) {
+        stream << this->getTargetConsumerId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of Compressed = " << this->isCompressed() << std::endl;
+    stream << " Value of RedeliveryCounter = " << this->getRedeliveryCounter() << 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 Arrival = " << this->getArrival() << std::endl;
+    stream << " Value of UserID = " << this->getUserID() << std::endl;
+    stream << " Value of RecievedByDFBridge = " << this->isRecievedByDFBridge() << std::endl;
+    stream << " Value of Droppable = " << this->isDroppable() << std::endl;
+    for( size_t icluster = 0; icluster < this->getCluster().size(); ++icluster ) {
+        stream << " Value of Cluster[" << icluster << "] is Below:" << std::endl;
+        if( this->getCluster()[icluster] != NULL ) {
+            stream << this->getCluster()[icluster]->toString() << std::endl;
+        } else {
+            stream << "   Object is NULL" << std::endl;
+        }
+    }
+    stream << " Value of BrokerInTime = " << this->getBrokerInTime() << std::endl;
+    stream << " Value of BrokerOutTime = " << this->getBrokerOutTime() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = Message" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::equals( const DataStructure* value ) const {
+    const Message* valuePtr = dynamic_cast<const Message*>( 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;
+    }
+    if( this->getTransactionId() != NULL ) {
+        if( !this->getTransactionId()->equals( valuePtr->getTransactionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getTransactionId() != NULL ) {
+        return false;
+    }
+    if( this->getOriginalDestination() != NULL ) {
+        if( !this->getOriginalDestination()->equals( valuePtr->getOriginalDestination() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getOriginalDestination() != NULL ) {
+        return false;
+    }
+    if( this->getMessageId() != NULL ) {
+        if( !this->getMessageId()->equals( valuePtr->getMessageId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getMessageId() != NULL ) {
+        return false;
+    }
+    if( this->getOriginalTransactionId() != NULL ) {
+        if( !this->getOriginalTransactionId()->equals( valuePtr->getOriginalTransactionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getOriginalTransactionId() != NULL ) {
+        return false;
+    }
+    if( this->getGroupID() != valuePtr->getGroupID() ) {
+        return false;
+    }
+    if( this->getGroupSequence() != valuePtr->getGroupSequence() ) {
+        return false;
+    }
+    if( this->getCorrelationId() != valuePtr->getCorrelationId() ) {
+        return false;
+    }
+    if( this->isPersistent() != valuePtr->isPersistent() ) {
+        return false;
+    }
+    if( this->getExpiration() != valuePtr->getExpiration() ) {
+        return false;
+    }
+    if( this->getPriority() != valuePtr->getPriority() ) {
+        return false;
+    }
+    if( this->getReplyTo() != NULL ) {
+        if( !this->getReplyTo()->equals( valuePtr->getReplyTo() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getReplyTo() != NULL ) {
+        return false;
+    }
+    if( this->getTimestamp() != valuePtr->getTimestamp() ) {
+        return false;
+    }
+    if( this->getType() != valuePtr->getType() ) {
+        return false;
+    }
+    for( size_t icontent = 0; icontent < this->getContent().size(); ++icontent ) {
+        if( this->getContent()[icontent] != valuePtr->getContent()[icontent] ) {
+            return false;
+        }
+    }
+    for( size_t imarshalledProperties = 0; imarshalledProperties < this->getMarshalledProperties().size(); ++imarshalledProperties ) {
+        if( this->getMarshalledProperties()[imarshalledProperties] != valuePtr->getMarshalledProperties()[imarshalledProperties] ) {
+            return false;
+        }
+    }
+    if( this->getDataStructure() != NULL ) {
+        if( !this->getDataStructure()->equals( valuePtr->getDataStructure() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getDataStructure() != NULL ) {
+        return false;
+    }
+    if( this->getTargetConsumerId() != NULL ) {
+        if( !this->getTargetConsumerId()->equals( valuePtr->getTargetConsumerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getTargetConsumerId() != NULL ) {
+        return false;
+    }
+    if( this->isCompressed() != valuePtr->isCompressed() ) {
+        return false;
+    }
+    if( this->getRedeliveryCounter() != valuePtr->getRedeliveryCounter() ) {
+        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->getArrival() != valuePtr->getArrival() ) {
+        return false;
+    }
+    if( this->getUserID() != valuePtr->getUserID() ) {
+        return false;
+    }
+    if( this->isRecievedByDFBridge() != valuePtr->isRecievedByDFBridge() ) {
+        return false;
+    }
+    if( this->isDroppable() != valuePtr->isDroppable() ) {
+        return false;
+    }
+    for( size_t icluster = 0; icluster < this->getCluster().size(); ++icluster ) {
+        if( this->getCluster()[icluster] != NULL ) {
+            if( !this->getCluster()[icluster]->equals( valuePtr->getCluster()[icluster] ) ) {
+                return false;
+            }
+        } else if( valuePtr->getCluster()[icluster] != NULL ) {
+            return false;
+        }
+    }
+    if( this->getBrokerInTime() != valuePtr->getBrokerInTime() ) {
+        return false;
+    }
+    if( this->getBrokerOutTime() != valuePtr->getBrokerOutTime() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned int Message::getSize() const {
+
+    unsigned int size = DEFAULT_MESSAGE_SIZE;
+
+    size += (unsigned int)this->getContent().size();
+    size += (unsigned int)this->getMarshalledProperties().size();
+
+    return size;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* Message::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* Message::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* Message::getTransactionId() const {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* Message::getTransactionId() {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTransactionId(TransactionId* transactionId ) {
+    this->transactionId = transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getOriginalDestination() const {
+    return originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getOriginalDestination() {
+    return originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setOriginalDestination(ActiveMQDestination* originalDestination ) {
+    this->originalDestination = originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* Message::getMessageId() const {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* Message::getMessageId() {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setMessageId(MessageId* messageId ) {
+    this->messageId = messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* Message::getOriginalTransactionId() const {
+    return originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* Message::getOriginalTransactionId() {
+    return originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setOriginalTransactionId(TransactionId* originalTransactionId ) {
+    this->originalTransactionId = originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getGroupID() const {
+    return groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getGroupID() {
+    return groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setGroupID(const std::string& groupID ) {
+    this->groupID = groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int Message::getGroupSequence() const {
+    return groupSequence;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setGroupSequence(int groupSequence ) {
+    this->groupSequence = groupSequence;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getCorrelationId() const {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getCorrelationId() {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCorrelationId(const std::string& correlationId ) {
+    this->correlationId = correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::isPersistent() const {
+    return persistent;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setPersistent(bool persistent ) {
+    this->persistent = persistent;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getExpiration() const {
+    return expiration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setExpiration(long long expiration ) {
+    this->expiration = expiration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char Message::getPriority() const {
+    return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setPriority(unsigned char priority ) {
+    this->priority = priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getReplyTo() const {
+    return replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getReplyTo() {
+    return replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setReplyTo(ActiveMQDestination* replyTo ) {
+    this->replyTo = replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getTimestamp() const {
+    return timestamp;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTimestamp(long long timestamp ) {
+    this->timestamp = timestamp;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getType() const {
+    return type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getType() {
+    return type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setType(const std::string& type ) {
+    this->type = type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<unsigned char>& Message::getContent() const {
+    return content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<unsigned char>& Message::getContent() {
+    return content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setContent(const std::vector<unsigned char>& content ) {
+    this->content = content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<unsigned char>& Message::getMarshalledProperties() const {
+    return marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<unsigned char>& Message::getMarshalledProperties() {
+    return marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setMarshalledProperties(const std::vector<unsigned char>& marshalledProperties ) {
+    this->marshalledProperties = marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const DataStructure* Message::getDataStructure() const {
+    return dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* Message::getDataStructure() {
+    return dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setDataStructure(DataStructure* dataStructure ) {
+    this->dataStructure = dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* Message::getTargetConsumerId() const {
+    return targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* Message::getTargetConsumerId() {
+    return targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTargetConsumerId(ConsumerId* targetConsumerId ) {
+    this->targetConsumerId = targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::isCompressed() const {
+    return compressed;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCompressed(bool compressed ) {
+    this->compressed = compressed;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int Message::getRedeliveryCounter() const {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setRedeliveryCounter(int redeliveryCounter ) {
+    this->redeliveryCounter = redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& Message::getBrokerPath() const {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& Message::getBrokerPath() {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerPath(const std::vector<BrokerId*>& brokerPath ) {
+    this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getArrival() const {
+    return arrival;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setArrival(long long arrival ) {
+    this->arrival = arrival;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getUserID() const {
+    return userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getUserID() {
+    return userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setUserID(const std::string& userID ) {
+    this->userID = userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::isRecievedByDFBridge() const {
+    return recievedByDFBridge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setRecievedByDFBridge(bool recievedByDFBridge ) {
+    this->recievedByDFBridge = recievedByDFBridge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::isDroppable() const {
+    return droppable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setDroppable(bool droppable ) {
+    this->droppable = droppable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*>& Message::getCluster() const {
+    return cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*>& Message::getCluster() {
+    return cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCluster(const std::vector<BrokerId*>& cluster ) {
+    this->cluster = cluster;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getBrokerInTime() const {
+    return brokerInTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerInTime(long long brokerInTime ) {
+    this->brokerInTime = brokerInTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getBrokerOutTime() const {
+    return brokerOutTime;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerOutTime(long long brokerOutTime ) {
+    this->brokerOutTime = brokerOutTime;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/Message.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,251 @@
+/*
+ * 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_MESSAGE_H_
+#define _ACTIVEMQ_COMMANDS_MESSAGE_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/TransactionId.h>
+#include <activemq/commands/ActiveMQDestination.h>
+#include <activemq/commands/MessageId.h>
+#include <activemq/commands/TransactionId.h>
+#include <activemq/commands/ActiveMQDestination.h>
+#include <activemq/commands/DataStructure.h>
+#include <activemq/commands/ConsumerId.h>
+#include <activemq/commands/BrokerId.h>
+#include <activemq/commands/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for Message
+     *
+     *
+     *  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 Message : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        static const unsigned int DEFAULT_MESSAGE_SIZE = 1024;
+
+        ProducerId* producerId;
+        ActiveMQDestination* destination;
+        TransactionId* transactionId;
+        ActiveMQDestination* originalDestination;
+        MessageId* messageId;
+        TransactionId* originalTransactionId;
+        std::string groupID;
+        int groupSequence;
+        std::string correlationId;
+        bool persistent;
+        long long expiration;
+        unsigned char priority;
+        ActiveMQDestination* replyTo;
+        long long timestamp;
+        std::string type;
+        std::vector<unsigned char> content;
+        std::vector<unsigned char> marshalledProperties;
+        DataStructure* dataStructure;
+        ConsumerId* targetConsumerId;
+        bool compressed;
+        int redeliveryCounter;
+        std::vector<BrokerId*> brokerPath;
+        long long arrival;
+        std::string userID;
+        bool recievedByDFBridge;
+        bool droppable;
+        std::vector<BrokerId*> cluster;
+        long long brokerInTime;
+        long long brokerOutTime;
+
+    public:
+
+        const static unsigned char ID_MESSAGE = 0;
+
+    public:
+
+        Message();
+        virtual ~Message();
+
+        /**
+         * 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 Message* 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;
+
+        /**
+         * Returns the Size of this message in Bytes.
+         * @returns number of bytes this message equates to.
+         */
+        virtual unsigned int getSize() 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 TransactionId* getTransactionId() const;
+        virtual TransactionId* getTransactionId();
+        virtual void setTransactionId( TransactionId* transactionId );
+
+        virtual const ActiveMQDestination* getOriginalDestination() const;
+        virtual ActiveMQDestination* getOriginalDestination();
+        virtual void setOriginalDestination( ActiveMQDestination* originalDestination );
+
+        virtual const MessageId* getMessageId() const;
+        virtual MessageId* getMessageId();
+        virtual void setMessageId( MessageId* messageId );
+
+        virtual const TransactionId* getOriginalTransactionId() const;
+        virtual TransactionId* getOriginalTransactionId();
+        virtual void setOriginalTransactionId( TransactionId* originalTransactionId );
+
+        virtual const std::string& getGroupID() const;
+        virtual std::string& getGroupID();
+        virtual void setGroupID( const std::string& groupID );
+
+        virtual int getGroupSequence() const;
+        virtual void setGroupSequence( int groupSequence );
+
+        virtual const std::string& getCorrelationId() const;
+        virtual std::string& getCorrelationId();
+        virtual void setCorrelationId( const std::string& correlationId );
+
+        virtual bool isPersistent() const;
+        virtual void setPersistent( bool persistent );
+
+        virtual long long getExpiration() const;
+        virtual void setExpiration( long long expiration );
+
+        virtual unsigned char getPriority() const;
+        virtual void setPriority( unsigned char priority );
+
+        virtual const ActiveMQDestination* getReplyTo() const;
+        virtual ActiveMQDestination* getReplyTo();
+        virtual void setReplyTo( ActiveMQDestination* replyTo );
+
+        virtual long long getTimestamp() const;
+        virtual void setTimestamp( long long timestamp );
+
+        virtual const std::string& getType() const;
+        virtual std::string& getType();
+        virtual void setType( const std::string& type );
+
+        virtual const std::vector<unsigned char>& getContent() const;
+        virtual std::vector<unsigned char>& getContent();
+        virtual void setContent( const std::vector<unsigned char>& content );
+
+        virtual const std::vector<unsigned char>& getMarshalledProperties() const;
+        virtual std::vector<unsigned char>& getMarshalledProperties();
+        virtual void setMarshalledProperties( const std::vector<unsigned char>& marshalledProperties );
+
+        virtual const DataStructure* getDataStructure() const;
+        virtual DataStructure* getDataStructure();
+        virtual void setDataStructure( DataStructure* dataStructure );
+
+        virtual const ConsumerId* getTargetConsumerId() const;
+        virtual ConsumerId* getTargetConsumerId();
+        virtual void setTargetConsumerId( ConsumerId* targetConsumerId );
+
+        virtual bool isCompressed() const;
+        virtual void setCompressed( bool compressed );
+
+        virtual int getRedeliveryCounter() const;
+        virtual void setRedeliveryCounter( int redeliveryCounter );
+
+        virtual const std::vector<BrokerId*>& getBrokerPath() const;
+        virtual std::vector<BrokerId*>& getBrokerPath();
+        virtual void setBrokerPath( const std::vector<BrokerId*>& brokerPath );
+
+        virtual long long getArrival() const;
+        virtual void setArrival( long long arrival );
+
+        virtual const std::string& getUserID() const;
+        virtual std::string& getUserID();
+        virtual void setUserID( const std::string& userID );
+
+        virtual bool isRecievedByDFBridge() const;
+        virtual void setRecievedByDFBridge( bool recievedByDFBridge );
+
+        virtual bool isDroppable() const;
+        virtual void setDroppable( bool droppable );
+
+        virtual const std::vector<BrokerId*>& getCluster() const;
+        virtual std::vector<BrokerId*>& getCluster();
+        virtual void setCluster( const std::vector<BrokerId*>& cluster );
+
+        virtual long long getBrokerInTime() const;
+        virtual void setBrokerInTime( long long brokerInTime );
+
+        virtual long long getBrokerOutTime() const;
+        virtual void setBrokerOutTime( long long brokerOutTime );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_MESSAGE_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,310 @@
+/*
+ * 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/MessageAck.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 MessageAck
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageAck::MessageAck()
+{
+    this->destination = NULL;
+    this->transactionId = NULL;
+    this->consumerId = NULL;
+    this->ackType = 0;
+    this->firstMessageId = NULL;
+    this->lastMessageId = NULL;
+    this->messageCount = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageAck::~MessageAck()
+{
+    delete this->destination;
+    delete this->transactionId;
+    delete this->consumerId;
+    delete this->firstMessageId;
+    delete this->lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageAck* MessageAck::cloneDataStructure() const {
+    MessageAck* messageAck = new MessageAck();
+
+    // Copy the data from the base class or classes
+    messageAck->copyDataStructure( this );
+
+    return messageAck;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const MessageAck* srcPtr = dynamic_cast<const MessageAck*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "MessageAck::copyDataStructure - src is NULL or invalid" );
+    }
+    if( srcPtr->getDestination() != NULL ) {
+        this->setDestination(
+            dynamic_cast<ActiveMQDestination*>(
+                srcPtr->getDestination()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getTransactionId() != NULL ) {
+        this->setTransactionId(
+            dynamic_cast<TransactionId*>(
+                srcPtr->getTransactionId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getConsumerId() != NULL ) {
+        this->setConsumerId(
+            dynamic_cast<ConsumerId*>(
+                srcPtr->getConsumerId()->cloneDataStructure() ) );
+    }
+    this->setAckType( srcPtr->getAckType() );
+    if( srcPtr->getFirstMessageId() != NULL ) {
+        this->setFirstMessageId(
+            dynamic_cast<MessageId*>(
+                srcPtr->getFirstMessageId()->cloneDataStructure() ) );
+    }
+    if( srcPtr->getLastMessageId() != NULL ) {
+        this->setLastMessageId(
+            dynamic_cast<MessageId*>(
+                srcPtr->getLastMessageId()->cloneDataStructure() ) );
+    }
+    this->setMessageCount( srcPtr->getMessageCount() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageAck::getDataStructureType() const {
+    return MessageAck::ID_MESSAGEACK;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string MessageAck::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = MessageAck" << std::endl;
+    stream << " Value of MessageAck::ID_MESSAGEACK = 22" << 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 TransactionId is Below:" << std::endl;
+    if( this->getTransactionId() != NULL ) {
+        stream << this->getTransactionId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of 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 AckType = " << (int)this->getAckType() << std::endl;
+    stream << " Value of FirstMessageId is Below:" << std::endl;
+    if( this->getFirstMessageId() != NULL ) {
+        stream << this->getFirstMessageId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of LastMessageId is Below:" << std::endl;
+    if( this->getLastMessageId() != NULL ) {
+        stream << this->getLastMessageId()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of MessageCount = " << this->getMessageCount() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = MessageAck" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool MessageAck::equals( const DataStructure* value ) const {
+    const MessageAck* valuePtr = dynamic_cast<const MessageAck*>( value );
+
+    if( valuePtr == NULL || value == NULL ) {
+        return false;
+    }
+    if( this->getDestination() != NULL ) {
+        if( !this->getDestination()->equals( valuePtr->getDestination() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getDestination() != NULL ) {
+        return false;
+    }
+    if( this->getTransactionId() != NULL ) {
+        if( !this->getTransactionId()->equals( valuePtr->getTransactionId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getTransactionId() != NULL ) {
+        return false;
+    }
+    if( this->getConsumerId() != NULL ) {
+        if( !this->getConsumerId()->equals( valuePtr->getConsumerId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getConsumerId() != NULL ) {
+        return false;
+    }
+    if( this->getAckType() != valuePtr->getAckType() ) {
+        return false;
+    }
+    if( this->getFirstMessageId() != NULL ) {
+        if( !this->getFirstMessageId()->equals( valuePtr->getFirstMessageId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getFirstMessageId() != NULL ) {
+        return false;
+    }
+    if( this->getLastMessageId() != NULL ) {
+        if( !this->getLastMessageId()->equals( valuePtr->getLastMessageId() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getLastMessageId() != NULL ) {
+        return false;
+    }
+    if( this->getMessageCount() != valuePtr->getMessageCount() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageAck::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageAck::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* MessageAck::getTransactionId() const {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* MessageAck::getTransactionId() {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setTransactionId(TransactionId* transactionId ) {
+    this->transactionId = transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessageAck::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageAck::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageAck::getAckType() const {
+    return ackType;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setAckType(unsigned char ackType ) {
+    this->ackType = ackType;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageAck::getFirstMessageId() const {
+    return firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageAck::getFirstMessageId() {
+    return firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setFirstMessageId(MessageId* firstMessageId ) {
+    this->firstMessageId = firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageAck::getLastMessageId() const {
+    return lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageAck::getLastMessageId() {
+    return lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setLastMessageId(MessageId* lastMessageId ) {
+    this->lastMessageId = lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int MessageAck::getMessageCount() const {
+    return messageCount;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setMessageCount(int messageCount ) {
+    this->messageCount = messageCount;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageAck.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,137 @@
+/*
+ * 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_MESSAGEACK_H_
+#define _ACTIVEMQ_COMMANDS_MESSAGEACK_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/ActiveMQDestination.h>
+#include <activemq/commands/TransactionId.h>
+#include <activemq/commands/ConsumerId.h>
+#include <activemq/commands/MessageId.h>
+#include <activemq/commands/MessageId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for MessageAck
+     *
+     *
+     *  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 MessageAck : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ActiveMQDestination* destination;
+        TransactionId* transactionId;
+        ConsumerId* consumerId;
+        unsigned char ackType;
+        MessageId* firstMessageId;
+        MessageId* lastMessageId;
+        int messageCount;
+
+    public:
+
+        const static unsigned char ID_MESSAGEACK = 22;
+
+    public:
+
+        MessageAck();
+        virtual ~MessageAck();
+
+        /**
+         * 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 MessageAck* 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 ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const TransactionId* getTransactionId() const;
+        virtual TransactionId* getTransactionId();
+        virtual void setTransactionId( TransactionId* transactionId );
+
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual unsigned char getAckType() const;
+        virtual void setAckType( unsigned char ackType );
+
+        virtual const MessageId* getFirstMessageId() const;
+        virtual MessageId* getFirstMessageId();
+        virtual void setFirstMessageId( MessageId* firstMessageId );
+
+        virtual const MessageId* getLastMessageId() const;
+        virtual MessageId* getLastMessageId();
+        virtual void setLastMessageId( MessageId* lastMessageId );
+
+        virtual int getMessageCount() const;
+        virtual void setMessageCount( int messageCount );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_MESSAGEACK_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,224 @@
+/*
+ * 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/MessageDispatch.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 MessageDispatch
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatch::MessageDispatch()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->message = NULL;
+    this->redeliveryCounter = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatch::~MessageDispatch()
+{
+    delete this->consumerId;
+    delete this->destination;
+    delete this->message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatch* MessageDispatch::cloneDataStructure() const {
+    MessageDispatch* messageDispatch = new MessageDispatch();
+
+    // Copy the data from the base class or classes
+    messageDispatch->copyDataStructure( this );
+
+    return messageDispatch;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const MessageDispatch* srcPtr = dynamic_cast<const MessageDispatch*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "MessageDispatch::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() ) );
+    }
+    if( srcPtr->getMessage() != NULL ) {
+        this->setMessage(
+            dynamic_cast<Message*>(
+                srcPtr->getMessage()->cloneDataStructure() ) );
+    }
+    this->setRedeliveryCounter( srcPtr->getRedeliveryCounter() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageDispatch::getDataStructureType() const {
+    return MessageDispatch::ID_MESSAGEDISPATCH;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string MessageDispatch::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = MessageDispatch" << std::endl;
+    stream << " Value of MessageDispatch::ID_MESSAGEDISPATCH = 21" << 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 Message is Below:" << std::endl;
+    if( this->getMessage() != NULL ) {
+        stream << this->getMessage()->toString() << std::endl;
+    } else {
+        stream << "   Object is NULL" << std::endl;
+    }
+    stream << " Value of RedeliveryCounter = " << this->getRedeliveryCounter() << std::endl;
+    stream << BaseCommand<transport::Command>::toString();
+    stream << "End Class = MessageDispatch" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool MessageDispatch::equals( const DataStructure* value ) const {
+    const MessageDispatch* valuePtr = dynamic_cast<const MessageDispatch*>( 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->getMessage() != NULL ) {
+        if( !this->getMessage()->equals( valuePtr->getMessage() ) ) {
+            return false;
+        }
+    } else if( valuePtr->getMessage() != NULL ) {
+        return false;
+    }
+    if( this->getRedeliveryCounter() != valuePtr->getRedeliveryCounter() ) {
+        return false;
+    }
+    if( !BaseCommand<transport::Command>::equals( value ) ) {
+        return false;
+    }
+    return true;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessageDispatch::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageDispatch::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageDispatch::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageDispatch::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const Message* MessageDispatch::getMessage() const {
+    return message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+Message* MessageDispatch::getMessage() {
+    return message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setMessage(Message* message ) {
+    this->message = message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int MessageDispatch::getRedeliveryCounter() const {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setRedeliveryCounter(int redeliveryCounter ) {
+    this->redeliveryCounter = redeliveryCounter;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatch.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,121 @@
+/*
+ * 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_MESSAGEDISPATCH_H_
+#define _ACTIVEMQ_COMMANDS_MESSAGEDISPATCH_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/Message.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshaling code for OpenWire format for MessageDispatch
+     *
+     *
+     *  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 MessageDispatch : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        ActiveMQDestination* destination;
+        Message* message;
+        int redeliveryCounter;
+
+    public:
+
+        const static unsigned char ID_MESSAGEDISPATCH = 21;
+
+    public:
+
+        MessageDispatch();
+        virtual ~MessageDispatch();
+
+        /**
+         * 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 MessageDispatch* 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 const Message* getMessage() const;
+        virtual Message* getMessage();
+        virtual void setMessage( Message* message );
+
+        virtual int getRedeliveryCounter() const;
+        virtual void setRedeliveryCounter( int redeliveryCounter );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_MESSAGEDISPATCH_H_*/
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.cpp?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.cpp (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.cpp Sun Jan 11 08:36:02 2009
@@ -0,0 +1,224 @@
+/*
+ * 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/MessageDispatchNotification.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 MessageDispatchNotification
+ *
+ *
+ *  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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatchNotification::MessageDispatchNotification()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->deliverySequenceId = 0;
+    this->messageId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatchNotification::~MessageDispatchNotification()
+{
+    delete this->consumerId;
+    delete this->destination;
+    delete this->messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatchNotification* MessageDispatchNotification::cloneDataStructure() const {
+    MessageDispatchNotification* messageDispatchNotification = new MessageDispatchNotification();
+
+    // Copy the data from the base class or classes
+    messageDispatchNotification->copyDataStructure( this );
+
+    return messageDispatchNotification;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::copyDataStructure( const DataStructure* src ) {
+
+    // Copy the data of the base class or classes
+    BaseCommand<transport::Command>::copyDataStructure( src );
+
+    const MessageDispatchNotification* srcPtr = dynamic_cast<const MessageDispatchNotification*>( src );
+
+    if( srcPtr == NULL || src == NULL ) {
+
+        throw decaf::lang::exceptions::NullPointerException(
+            __FILE__, __LINE__,
+            "MessageDispatchNotification::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->setDeliverySequenceId( srcPtr->getDeliverySequenceId() );
+    if( srcPtr->getMessageId() != NULL ) {
+        this->setMessageId(
+            dynamic_cast<MessageId*>(
+                srcPtr->getMessageId()->cloneDataStructure() ) );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageDispatchNotification::getDataStructureType() const {
+    return MessageDispatchNotification::ID_MESSAGEDISPATCHNOTIFICATION;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string MessageDispatchNotification::toString() const {
+
+    ostringstream stream;
+
+    stream << "Begin Class = MessageDispatchNotification" << std::endl;
+    stream << " Value of MessageDispatchNotification::ID_MESSAGEDISPATCHNOTIFICATION = 90" << 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 DeliverySequenceId = " << this->getDeliverySequenceId() << 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 = MessageDispatchNotification" << std::endl;
+
+    return stream.str();
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool MessageDispatchNotification::equals( const DataStructure* value ) const {
+    const MessageDispatchNotification* valuePtr = dynamic_cast<const MessageDispatchNotification*>( 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->getDeliverySequenceId() != valuePtr->getDeliverySequenceId() ) {
+        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* MessageDispatchNotification::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageDispatchNotification::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageDispatchNotification::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageDispatchNotification::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageDispatchNotification::getDeliverySequenceId() const {
+    return deliverySequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setDeliverySequenceId(long long deliverySequenceId ) {
+    this->deliverySequenceId = deliverySequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageDispatchNotification::getMessageId() const {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageDispatchNotification::getMessageId() {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setMessageId(MessageId* messageId ) {
+    this->messageId = messageId;
+}
+

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

Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.h?rev=733487&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.h (added)
+++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageDispatchNotification.h Sun Jan 11 08:36:02 2009
@@ -0,0 +1,121 @@
+/*
+ * 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_MESSAGEDISPATCHNOTIFICATION_H_
+#define _ACTIVEMQ_COMMANDS_MESSAGEDISPATCHNOTIFICATION_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 MessageDispatchNotification
+     *
+     *
+     *  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 MessageDispatchNotification : public BaseCommand<transport::Command>
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        ActiveMQDestination* destination;
+        long long deliverySequenceId;
+        MessageId* messageId;
+
+    public:
+
+        const static unsigned char ID_MESSAGEDISPATCHNOTIFICATION = 90;
+
+    public:
+
+        MessageDispatchNotification();
+        virtual ~MessageDispatchNotification();
+
+        /**
+         * 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 MessageDispatchNotification* 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 getDeliverySequenceId() const;
+        virtual void setDeliverySequenceId( long long deliverySequenceId );
+
+        virtual const MessageId* getMessageId() const;
+        virtual MessageId* getMessageId();
+        virtual void setMessageId( MessageId* messageId );
+
+    };
+
+}}
+
+#endif /*_ACTIVEMQ_COMMANDS_MESSAGEDISPATCHNOTIFICATION_H_*/
+

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



Mime
View raw message