Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 97248 invoked from network); 11 Jan 2009 16:37:00 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 11 Jan 2009 16:37:00 -0000 Received: (qmail 78310 invoked by uid 500); 11 Jan 2009 16:37:00 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 78253 invoked by uid 500); 11 Jan 2009 16:37:00 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 78244 invoked by uid 99); 11 Jan 2009 16:37:00 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 11 Jan 2009 08:37:00 -0800 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 11 Jan 2009 16:36:54 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 7768C2388B5E; Sun, 11 Jan 2009 08:36:10 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r733487 [6/10] - /activemq/activemq-cpp/trunk/src/main/activemq/commands/ Date: Sun, 11 Jan 2009 16:36:05 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090111163610.7768C2388B5E@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,173 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#include +#include + +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 JournalQueueAck + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +JournalQueueAck::JournalQueueAck() +{ + this->destination = NULL; + this->messageAck = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalQueueAck::~JournalQueueAck() +{ + delete this->destination; + delete this->messageAck; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalQueueAck* JournalQueueAck::cloneDataStructure() const { + JournalQueueAck* journalQueueAck = new JournalQueueAck(); + + // Copy the data from the base class or classes + journalQueueAck->copyDataStructure( this ); + + return journalQueueAck; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalQueueAck::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const JournalQueueAck* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "JournalQueueAck::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getDestination() != NULL ) { + this->setDestination( + dynamic_cast( + srcPtr->getDestination()->cloneDataStructure() ) ); + } + if( srcPtr->getMessageAck() != NULL ) { + this->setMessageAck( + dynamic_cast( + srcPtr->getMessageAck()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char JournalQueueAck::getDataStructureType() const { + return JournalQueueAck::ID_JOURNALQUEUEACK; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string JournalQueueAck::toString() const { + + ostringstream stream; + + stream << "Begin Class = JournalQueueAck" << std::endl; + stream << " Value of JournalQueueAck::ID_JOURNALQUEUEACK = 52" << 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 MessageAck is Below:" << std::endl; + if( this->getMessageAck() != NULL ) { + stream << this->getMessageAck()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << BaseDataStructure::toString(); + stream << "End Class = JournalQueueAck" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool JournalQueueAck::equals( const DataStructure* value ) const { + const JournalQueueAck* valuePtr = dynamic_cast( 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->getMessageAck() != NULL ) { + if( !this->getMessageAck()->equals( valuePtr->getMessageAck() ) ) { + return false; + } + } else if( valuePtr->getMessageAck() != NULL ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ActiveMQDestination* JournalQueueAck::getDestination() const { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +ActiveMQDestination* JournalQueueAck::getDestination() { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalQueueAck::setDestination(ActiveMQDestination* destination ) { + this->destination = destination; +} + +//////////////////////////////////////////////////////////////////////////////// +const MessageAck* JournalQueueAck::getMessageAck() const { + return messageAck; +} + +//////////////////////////////////////////////////////////////////////////////// +MessageAck* JournalQueueAck::getMessageAck() { + return messageAck; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalQueueAck::setMessageAck(MessageAck* messageAck ) { + this->messageAck = messageAck; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,111 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_JOURNALQUEUEACK_H_ +#define _ACTIVEMQ_COMMANDS_JOURNALQUEUEACK_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for JournalQueueAck + * + * + * 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 JournalQueueAck : public BaseDataStructure + { + protected: + + ActiveMQDestination* destination; + MessageAck* messageAck; + + public: + + const static unsigned char ID_JOURNALQUEUEACK = 52; + + public: + + JournalQueueAck(); + virtual ~JournalQueueAck(); + + /** + * 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 JournalQueueAck* 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 MessageAck* getMessageAck() const; + virtual MessageAck* getMessageAck(); + virtual void setMessageAck( MessageAck* messageAck ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_JOURNALQUEUEACK_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalQueueAck.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,266 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#include +#include + +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 JournalTopicAck + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +JournalTopicAck::JournalTopicAck() +{ + this->destination = NULL; + this->messageId = NULL; + this->messageSequenceId = 0; + this->subscritionName = ""; + this->clientId = ""; + this->transactionId = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTopicAck::~JournalTopicAck() +{ + delete this->destination; + delete this->messageId; + delete this->transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTopicAck* JournalTopicAck::cloneDataStructure() const { + JournalTopicAck* journalTopicAck = new JournalTopicAck(); + + // Copy the data from the base class or classes + journalTopicAck->copyDataStructure( this ); + + return journalTopicAck; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const JournalTopicAck* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "JournalTopicAck::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getDestination() != NULL ) { + this->setDestination( + dynamic_cast( + srcPtr->getDestination()->cloneDataStructure() ) ); + } + if( srcPtr->getMessageId() != NULL ) { + this->setMessageId( + dynamic_cast( + srcPtr->getMessageId()->cloneDataStructure() ) ); + } + this->setMessageSequenceId( srcPtr->getMessageSequenceId() ); + this->setSubscritionName( srcPtr->getSubscritionName() ); + this->setClientId( srcPtr->getClientId() ); + if( srcPtr->getTransactionId() != NULL ) { + this->setTransactionId( + dynamic_cast( + srcPtr->getTransactionId()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTopicAck::getDataStructureType() const { + return JournalTopicAck::ID_JOURNALTOPICACK; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string JournalTopicAck::toString() const { + + ostringstream stream; + + stream << "Begin Class = JournalTopicAck" << std::endl; + stream << " Value of JournalTopicAck::ID_JOURNALTOPICACK = 50" << 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 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 MessageSequenceId = " << this->getMessageSequenceId() << std::endl; + stream << " Value of SubscritionName = " << this->getSubscritionName() << std::endl; + stream << " Value of ClientId = " << this->getClientId() << 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 << BaseDataStructure::toString(); + stream << "End Class = JournalTopicAck" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool JournalTopicAck::equals( const DataStructure* value ) const { + const JournalTopicAck* valuePtr = dynamic_cast( 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->getMessageId() != NULL ) { + if( !this->getMessageId()->equals( valuePtr->getMessageId() ) ) { + return false; + } + } else if( valuePtr->getMessageId() != NULL ) { + return false; + } + if( this->getMessageSequenceId() != valuePtr->getMessageSequenceId() ) { + return false; + } + if( this->getSubscritionName() != valuePtr->getSubscritionName() ) { + return false; + } + if( this->getClientId() != valuePtr->getClientId() ) { + return false; + } + if( this->getTransactionId() != NULL ) { + if( !this->getTransactionId()->equals( valuePtr->getTransactionId() ) ) { + return false; + } + } else if( valuePtr->getTransactionId() != NULL ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ActiveMQDestination* JournalTopicAck::getDestination() const { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +ActiveMQDestination* JournalTopicAck::getDestination() { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setDestination(ActiveMQDestination* destination ) { + this->destination = destination; +} + +//////////////////////////////////////////////////////////////////////////////// +const MessageId* JournalTopicAck::getMessageId() const { + return messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +MessageId* JournalTopicAck::getMessageId() { + return messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setMessageId(MessageId* messageId ) { + this->messageId = messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +long long JournalTopicAck::getMessageSequenceId() const { + return messageSequenceId; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setMessageSequenceId(long long messageSequenceId ) { + this->messageSequenceId = messageSequenceId; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::string& JournalTopicAck::getSubscritionName() const { + return subscritionName; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string& JournalTopicAck::getSubscritionName() { + return subscritionName; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setSubscritionName(const std::string& subscritionName ) { + this->subscritionName = subscritionName; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::string& JournalTopicAck::getClientId() const { + return clientId; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string& JournalTopicAck::getClientId() { + return clientId; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setClientId(const std::string& clientId ) { + this->clientId = clientId; +} + +//////////////////////////////////////////////////////////////////////////////// +const TransactionId* JournalTopicAck::getTransactionId() const { + return transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +TransactionId* JournalTopicAck::getTransactionId() { + return transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTopicAck::setTransactionId(TransactionId* transactionId ) { + this->transactionId = transactionId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,131 @@ +/* + * 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_JOURNALTOPICACK_H_ +#define _ACTIVEMQ_COMMANDS_JOURNALTOPICACK_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for JournalTopicAck + * + * + * 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 JournalTopicAck : public BaseDataStructure + { + protected: + + ActiveMQDestination* destination; + MessageId* messageId; + long long messageSequenceId; + std::string subscritionName; + std::string clientId; + TransactionId* transactionId; + + public: + + const static unsigned char ID_JOURNALTOPICACK = 50; + + public: + + JournalTopicAck(); + virtual ~JournalTopicAck(); + + /** + * 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 JournalTopicAck* 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 MessageId* getMessageId() const; + virtual MessageId* getMessageId(); + virtual void setMessageId( MessageId* messageId ); + + virtual long long getMessageSequenceId() const; + virtual void setMessageSequenceId( long long messageSequenceId ); + + virtual const std::string& getSubscritionName() const; + virtual std::string& getSubscritionName(); + virtual void setSubscritionName( const std::string& subscritionName ); + + virtual const std::string& getClientId() const; + virtual std::string& getClientId(); + virtual void setClientId( const std::string& clientId ); + + virtual const TransactionId* getTransactionId() const; + virtual TransactionId* getTransactionId(); + virtual void setTransactionId( TransactionId* transactionId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_JOURNALTOPICACK_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTopicAck.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#include +#include + +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 JournalTrace + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +JournalTrace::JournalTrace() +{ + this->message = ""; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTrace::~JournalTrace() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTrace* JournalTrace::cloneDataStructure() const { + JournalTrace* journalTrace = new JournalTrace(); + + // Copy the data from the base class or classes + journalTrace->copyDataStructure( this ); + + return journalTrace; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTrace::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const JournalTrace* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "JournalTrace::copyDataStructure - src is NULL or invalid" ); + } + this->setMessage( srcPtr->getMessage() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTrace::getDataStructureType() const { + return JournalTrace::ID_JOURNALTRACE; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string JournalTrace::toString() const { + + ostringstream stream; + + stream << "Begin Class = JournalTrace" << std::endl; + stream << " Value of JournalTrace::ID_JOURNALTRACE = 53" << std::endl; + stream << " Value of Message = " << this->getMessage() << std::endl; + stream << BaseDataStructure::toString(); + stream << "End Class = JournalTrace" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool JournalTrace::equals( const DataStructure* value ) const { + const JournalTrace* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getMessage() != valuePtr->getMessage() ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::string& JournalTrace::getMessage() const { + return message; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string& JournalTrace::getMessage() { + return message; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTrace::setMessage(const std::string& message ) { + this->message = message; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_JOURNALTRACE_H_ +#define _ACTIVEMQ_COMMANDS_JOURNALTRACE_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for JournalTrace + * + * + * 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 JournalTrace : public BaseDataStructure + { + protected: + + std::string message; + + public: + + const static unsigned char ID_JOURNALTRACE = 53; + + public: + + JournalTrace(); + virtual ~JournalTrace(); + + /** + * 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 JournalTrace* 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& getMessage() const; + virtual std::string& getMessage(); + virtual void setMessage( const std::string& message ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_JOURNALTRACE_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTrace.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.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 +#include +#include + +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 JournalTransaction + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +JournalTransaction::JournalTransaction() +{ + this->transactionId = NULL; + this->type = 0; + this->wasPrepared = false; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTransaction::~JournalTransaction() +{ + delete this->transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +JournalTransaction* JournalTransaction::cloneDataStructure() const { + JournalTransaction* journalTransaction = new JournalTransaction(); + + // Copy the data from the base class or classes + journalTransaction->copyDataStructure( this ); + + return journalTransaction; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTransaction::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const JournalTransaction* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "JournalTransaction::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getTransactionId() != NULL ) { + this->setTransactionId( + dynamic_cast( + srcPtr->getTransactionId()->cloneDataStructure() ) ); + } + this->setType( srcPtr->getType() ); + this->setWasPrepared( srcPtr->getWasPrepared() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTransaction::getDataStructureType() const { + return JournalTransaction::ID_JOURNALTRANSACTION; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string JournalTransaction::toString() const { + + ostringstream stream; + + stream << "Begin Class = JournalTransaction" << std::endl; + stream << " Value of JournalTransaction::ID_JOURNALTRANSACTION = 54" << std::endl; + stream << " Value of TransactionId is Below:" << std::endl; + if( this->getTransactionId() != NULL ) { + stream << this->getTransactionId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of Type = " << (int)this->getType() << std::endl; + stream << " Value of WasPrepared = " << this->getWasPrepared() << std::endl; + stream << BaseDataStructure::toString(); + stream << "End Class = JournalTransaction" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool JournalTransaction::equals( const DataStructure* value ) const { + const JournalTransaction* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getTransactionId() != NULL ) { + if( !this->getTransactionId()->equals( valuePtr->getTransactionId() ) ) { + return false; + } + } else if( valuePtr->getTransactionId() != NULL ) { + return false; + } + if( this->getType() != valuePtr->getType() ) { + return false; + } + if( this->getWasPrepared() != valuePtr->getWasPrepared() ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const TransactionId* JournalTransaction::getTransactionId() const { + return transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +TransactionId* JournalTransaction::getTransactionId() { + return transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTransaction::setTransactionId(TransactionId* transactionId ) { + this->transactionId = transactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char JournalTransaction::getType() const { + return type; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTransaction::setType(unsigned char type ) { + this->type = type; +} + +//////////////////////////////////////////////////////////////////////////////// +bool JournalTransaction::getWasPrepared() const { + return wasPrepared; +} + +//////////////////////////////////////////////////////////////////////////////// +void JournalTransaction::setWasPrepared(bool wasPrepared ) { + this->wasPrepared = wasPrepared; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.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_JOURNALTRANSACTION_H_ +#define _ACTIVEMQ_COMMANDS_JOURNALTRANSACTION_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for JournalTransaction + * + * + * 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 JournalTransaction : public BaseDataStructure + { + protected: + + TransactionId* transactionId; + unsigned char type; + bool wasPrepared; + + public: + + const static unsigned char ID_JOURNALTRANSACTION = 54; + + public: + + JournalTransaction(); + virtual ~JournalTransaction(); + + /** + * 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 JournalTransaction* 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 TransactionId* getTransactionId() const; + virtual TransactionId* getTransactionId(); + virtual void setTransactionId( TransactionId* transactionId ); + + virtual unsigned char getType() const; + virtual void setType( unsigned char type ); + + virtual bool getWasPrepared() const; + virtual void setWasPrepared( bool wasPrepared ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_JOURNALTRANSACTION_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/JournalTransaction.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#include +#include + +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 KeepAliveInfo + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +KeepAliveInfo::KeepAliveInfo() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +KeepAliveInfo::~KeepAliveInfo() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +KeepAliveInfo* KeepAliveInfo::cloneDataStructure() const { + KeepAliveInfo* keepAliveInfo = new KeepAliveInfo(); + + // Copy the data from the base class or classes + keepAliveInfo->copyDataStructure( this ); + + return keepAliveInfo; +} + +//////////////////////////////////////////////////////////////////////////////// +void KeepAliveInfo::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseCommand::copyDataStructure( src ); + + const KeepAliveInfo* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "KeepAliveInfo::copyDataStructure - src is NULL or invalid" ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char KeepAliveInfo::getDataStructureType() const { + return KeepAliveInfo::ID_KEEPALIVEINFO; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string KeepAliveInfo::toString() const { + + ostringstream stream; + + stream << "Begin Class = KeepAliveInfo" << std::endl; + stream << " Value of KeepAliveInfo::ID_KEEPALIVEINFO = 10" << std::endl; + stream << BaseCommand::toString(); + stream << "End Class = KeepAliveInfo" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool KeepAliveInfo::equals( const DataStructure* value ) const { + const KeepAliveInfo* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( !BaseCommand::equals( value ) ) { + return false; + } + return true; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,99 @@ +/* + * 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_KEEPALIVEINFO_H_ +#define _ACTIVEMQ_COMMANDS_KEEPALIVEINFO_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for KeepAliveInfo + * + * + * 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 KeepAliveInfo : public BaseCommand + { + protected: + + + public: + + const static unsigned char ID_KEEPALIVEINFO = 10; + + public: + + KeepAliveInfo(); + virtual ~KeepAliveInfo(); + + /** + * 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 KeepAliveInfo* 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; + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_KEEPALIVEINFO_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/KeepAliveInfo.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#include +#include + +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 LastPartialCommand + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +LastPartialCommand::LastPartialCommand() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +LastPartialCommand::~LastPartialCommand() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +LastPartialCommand* LastPartialCommand::cloneDataStructure() const { + LastPartialCommand* lastPartialCommand = new LastPartialCommand(); + + // Copy the data from the base class or classes + lastPartialCommand->copyDataStructure( this ); + + return lastPartialCommand; +} + +//////////////////////////////////////////////////////////////////////////////// +void LastPartialCommand::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + PartialCommand::copyDataStructure( src ); + + const LastPartialCommand* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "LastPartialCommand::copyDataStructure - src is NULL or invalid" ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char LastPartialCommand::getDataStructureType() const { + return LastPartialCommand::ID_LASTPARTIALCOMMAND; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string LastPartialCommand::toString() const { + + ostringstream stream; + + stream << "Begin Class = LastPartialCommand" << std::endl; + stream << " Value of LastPartialCommand::ID_LASTPARTIALCOMMAND = 61" << std::endl; + stream << PartialCommand::toString(); + stream << "End Class = LastPartialCommand" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool LastPartialCommand::equals( const DataStructure* value ) const { + const LastPartialCommand* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( !PartialCommand::equals( value ) ) { + return false; + } + return true; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,99 @@ +/* + * 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_LASTPARTIALCOMMAND_H_ +#define _ACTIVEMQ_COMMANDS_LASTPARTIALCOMMAND_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for LastPartialCommand + * + * + * 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 LastPartialCommand : public PartialCommand + { + protected: + + + public: + + const static unsigned char ID_LASTPARTIALCOMMAND = 61; + + public: + + LastPartialCommand(); + virtual ~LastPartialCommand(); + + /** + * 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 LastPartialCommand* 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; + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_LASTPARTIALCOMMAND_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/LastPartialCommand.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.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 +#include +#include + +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 LocalTransactionId + * + * + * 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 + * + */ +//////////////////////////////////////////////////////////////////////////////// +LocalTransactionId::LocalTransactionId() +{ + this->value = 0; + this->connectionId = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +LocalTransactionId::~LocalTransactionId() +{ + delete this->connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +LocalTransactionId* LocalTransactionId::cloneDataStructure() const { + LocalTransactionId* localTransactionId = new LocalTransactionId(); + + // Copy the data from the base class or classes + localTransactionId->copyDataStructure( this ); + + return localTransactionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void LocalTransactionId::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + TransactionId::copyDataStructure( src ); + + const LocalTransactionId* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "LocalTransactionId::copyDataStructure - src is NULL or invalid" ); + } + this->setValue( srcPtr->getValue() ); + if( srcPtr->getConnectionId() != NULL ) { + this->setConnectionId( + dynamic_cast( + srcPtr->getConnectionId()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char LocalTransactionId::getDataStructureType() const { + return LocalTransactionId::ID_LOCALTRANSACTIONID; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string LocalTransactionId::toString() const { + + ostringstream stream; + + stream << "Begin Class = LocalTransactionId" << std::endl; + stream << " Value of LocalTransactionId::ID_LOCALTRANSACTIONID = 111" << std::endl; + stream << " Value of Value = " << this->getValue() << std::endl; + stream << " Value of ConnectionId is Below:" << std::endl; + if( this->getConnectionId() != NULL ) { + stream << this->getConnectionId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << TransactionId::toString(); + stream << "End Class = LocalTransactionId" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool LocalTransactionId::equals( const DataStructure* value ) const { + const LocalTransactionId* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getValue() != valuePtr->getValue() ) { + return false; + } + if( this->getConnectionId() != NULL ) { + if( !this->getConnectionId()->equals( valuePtr->getConnectionId() ) ) { + return false; + } + } else if( valuePtr->getConnectionId() != NULL ) { + return false; + } + if( !TransactionId::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +long long LocalTransactionId::getValue() const { + return value; +} + +//////////////////////////////////////////////////////////////////////////////// +void LocalTransactionId::setValue(long long value ) { + this->value = value; +} + +//////////////////////////////////////////////////////////////////////////////// +const ConnectionId* LocalTransactionId::getConnectionId() const { + return connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +ConnectionId* LocalTransactionId::getConnectionId() { + return connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void LocalTransactionId::setConnectionId(ConnectionId* connectionId ) { + this->connectionId = connectionId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.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_LOCALTRANSACTIONID_H_ +#define _ACTIVEMQ_COMMANDS_LOCALTRANSACTIONID_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for LocalTransactionId + * + * + * 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 LocalTransactionId : public TransactionId + { + protected: + + long long value; + ConnectionId* connectionId; + + public: + + const static unsigned char ID_LOCALTRANSACTIONID = 111; + + public: + + LocalTransactionId(); + virtual ~LocalTransactionId(); + + /** + * 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 LocalTransactionId* 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 long long getValue() const; + virtual void setValue( long long value ); + + virtual const ConnectionId* getConnectionId() const; + virtual ConnectionId* getConnectionId(); + virtual void setConnectionId( ConnectionId* connectionId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_LOCALTRANSACTIONID_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/LocalTransactionId.h ------------------------------------------------------------------------------ svn:eol-style = native