Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 97299 invoked from network); 11 Jan 2009 16:37:01 -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:01 -0000 Received: (qmail 78469 invoked by uid 500); 11 Jan 2009 16:37:01 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 78343 invoked by uid 500); 11 Jan 2009 16:37:01 -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 78317 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 8AFE42388B67; 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 [8/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.8AFE42388B67@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,170 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 MessageId + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +MessageId::MessageId() +{ + this->producerId = NULL; + this->producerSequenceId = 0; + this->brokerSequenceId = 0; +} + +//////////////////////////////////////////////////////////////////////////////// +MessageId::~MessageId() +{ + delete this->producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +MessageId* MessageId::cloneDataStructure() const { + MessageId* messageId = new MessageId(); + + // Copy the data from the base class or classes + messageId->copyDataStructure( this ); + + return messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessageId::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const MessageId* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "MessageId::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getProducerId() != NULL ) { + this->setProducerId( + dynamic_cast( + srcPtr->getProducerId()->cloneDataStructure() ) ); + } + this->setProducerSequenceId( srcPtr->getProducerSequenceId() ); + this->setBrokerSequenceId( srcPtr->getBrokerSequenceId() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char MessageId::getDataStructureType() const { + return MessageId::ID_MESSAGEID; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string MessageId::toString() const { + + ostringstream stream; + + stream << "Begin Class = MessageId" << std::endl; + stream << " Value of MessageId::ID_MESSAGEID = 110" << std::endl; + stream << " Value of ProducerId is Below:" << std::endl; + if( this->getProducerId() != NULL ) { + stream << this->getProducerId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of ProducerSequenceId = " << this->getProducerSequenceId() << std::endl; + stream << " Value of BrokerSequenceId = " << this->getBrokerSequenceId() << std::endl; + stream << BaseDataStructure::toString(); + stream << "End Class = MessageId" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool MessageId::equals( const DataStructure* value ) const { + const MessageId* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getProducerId() != NULL ) { + if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) { + return false; + } + } else if( valuePtr->getProducerId() != NULL ) { + return false; + } + if( this->getProducerSequenceId() != valuePtr->getProducerSequenceId() ) { + return false; + } + if( this->getBrokerSequenceId() != valuePtr->getBrokerSequenceId() ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ProducerId* MessageId::getProducerId() const { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerId* MessageId::getProducerId() { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessageId::setProducerId(ProducerId* producerId ) { + this->producerId = producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +long long MessageId::getProducerSequenceId() const { + return producerSequenceId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessageId::setProducerSequenceId(long long producerSequenceId ) { + this->producerSequenceId = producerSequenceId; +} + +//////////////////////////////////////////////////////////////////////////////// +long long MessageId::getBrokerSequenceId() const { + return brokerSequenceId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessageId::setBrokerSequenceId(long long brokerSequenceId ) { + this->brokerSequenceId = brokerSequenceId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,113 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_MESSAGEID_H_ +#define _ACTIVEMQ_COMMANDS_MESSAGEID_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for MessageId + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API MessageId : public BaseDataStructure + { + protected: + + ProducerId* producerId; + long long producerSequenceId; + long long brokerSequenceId; + + public: + + const static unsigned char ID_MESSAGEID = 110; + + public: + + MessageId(); + virtual ~MessageId(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual MessageId* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual const ProducerId* getProducerId() const; + virtual ProducerId* getProducerId(); + virtual void setProducerId( ProducerId* producerId ); + + virtual long long getProducerSequenceId() const; + virtual void setProducerSequenceId( long long producerSequenceId ); + + virtual long long getBrokerSequenceId() const; + virtual void setBrokerSequenceId( long long brokerSequenceId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_MESSAGEID_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessageId.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,245 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 MessagePull + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +MessagePull::MessagePull() +{ + this->consumerId = NULL; + this->destination = NULL; + this->timeout = 0; + this->correlationId = ""; + this->messageId = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +MessagePull::~MessagePull() +{ + delete this->consumerId; + delete this->destination; + delete this->messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +MessagePull* MessagePull::cloneDataStructure() const { + MessagePull* messagePull = new MessagePull(); + + // Copy the data from the base class or classes + messagePull->copyDataStructure( this ); + + return messagePull; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseCommand::copyDataStructure( src ); + + const MessagePull* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "MessagePull::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getConsumerId() != NULL ) { + this->setConsumerId( + dynamic_cast( + srcPtr->getConsumerId()->cloneDataStructure() ) ); + } + if( srcPtr->getDestination() != NULL ) { + this->setDestination( + dynamic_cast( + srcPtr->getDestination()->cloneDataStructure() ) ); + } + this->setTimeout( srcPtr->getTimeout() ); + this->setCorrelationId( srcPtr->getCorrelationId() ); + if( srcPtr->getMessageId() != NULL ) { + this->setMessageId( + dynamic_cast( + srcPtr->getMessageId()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char MessagePull::getDataStructureType() const { + return MessagePull::ID_MESSAGEPULL; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string MessagePull::toString() const { + + ostringstream stream; + + stream << "Begin Class = MessagePull" << std::endl; + stream << " Value of MessagePull::ID_MESSAGEPULL = 20" << std::endl; + stream << " Value of ConsumerId is Below:" << std::endl; + if( this->getConsumerId() != NULL ) { + stream << this->getConsumerId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of Destination is Below:" << std::endl; + if( this->getDestination() != NULL ) { + stream << this->getDestination()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of Timeout = " << this->getTimeout() << std::endl; + stream << " Value of CorrelationId = " << this->getCorrelationId() << std::endl; + stream << " Value of MessageId is Below:" << std::endl; + if( this->getMessageId() != NULL ) { + stream << this->getMessageId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << BaseCommand::toString(); + stream << "End Class = MessagePull" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool MessagePull::equals( const DataStructure* value ) const { + const MessagePull* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getConsumerId() != NULL ) { + if( !this->getConsumerId()->equals( valuePtr->getConsumerId() ) ) { + return false; + } + } else if( valuePtr->getConsumerId() != NULL ) { + return false; + } + if( this->getDestination() != NULL ) { + if( !this->getDestination()->equals( valuePtr->getDestination() ) ) { + return false; + } + } else if( valuePtr->getDestination() != NULL ) { + return false; + } + if( this->getTimeout() != valuePtr->getTimeout() ) { + return false; + } + if( this->getCorrelationId() != valuePtr->getCorrelationId() ) { + return false; + } + if( this->getMessageId() != NULL ) { + if( !this->getMessageId()->equals( valuePtr->getMessageId() ) ) { + return false; + } + } else if( valuePtr->getMessageId() != NULL ) { + return false; + } + if( !BaseCommand::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ConsumerId* MessagePull::getConsumerId() const { + return consumerId; +} + +//////////////////////////////////////////////////////////////////////////////// +ConsumerId* MessagePull::getConsumerId() { + return consumerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::setConsumerId(ConsumerId* consumerId ) { + this->consumerId = consumerId; +} + +//////////////////////////////////////////////////////////////////////////////// +const ActiveMQDestination* MessagePull::getDestination() const { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +ActiveMQDestination* MessagePull::getDestination() { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::setDestination(ActiveMQDestination* destination ) { + this->destination = destination; +} + +//////////////////////////////////////////////////////////////////////////////// +long long MessagePull::getTimeout() const { + return timeout; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::setTimeout(long long timeout ) { + this->timeout = timeout; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::string& MessagePull::getCorrelationId() const { + return correlationId; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string& MessagePull::getCorrelationId() { + return correlationId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::setCorrelationId(const std::string& correlationId ) { + this->correlationId = correlationId; +} + +//////////////////////////////////////////////////////////////////////////////// +const MessageId* MessagePull::getMessageId() const { + return messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +MessageId* MessagePull::getMessageId() { + return messageId; +} + +//////////////////////////////////////////////////////////////////////////////// +void MessagePull::setMessageId(MessageId* messageId ) { + this->messageId = messageId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,126 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_MESSAGEPULL_H_ +#define _ACTIVEMQ_COMMANDS_MESSAGEPULL_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for MessagePull + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API MessagePull : public BaseCommand + { + protected: + + ConsumerId* consumerId; + ActiveMQDestination* destination; + long long timeout; + std::string correlationId; + MessageId* messageId; + + public: + + const static unsigned char ID_MESSAGEPULL = 20; + + public: + + MessagePull(); + virtual ~MessagePull(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual MessagePull* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual const ConsumerId* getConsumerId() const; + virtual ConsumerId* getConsumerId(); + virtual void setConsumerId( ConsumerId* consumerId ); + + virtual const ActiveMQDestination* getDestination() const; + virtual ActiveMQDestination* getDestination(); + virtual void setDestination( ActiveMQDestination* destination ); + + virtual long long getTimeout() const; + virtual void setTimeout( long long timeout ); + + virtual const std::string& getCorrelationId() const; + virtual std::string& getCorrelationId(); + virtual void setCorrelationId( const std::string& correlationId ); + + virtual const MessageId* getMessageId() const; + virtual MessageId* getMessageId(); + virtual void setMessageId( MessageId* messageId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_MESSAGEPULL_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/MessagePull.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 NetworkBridgeFilter + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +NetworkBridgeFilter::NetworkBridgeFilter() +{ + this->networkTTL = 0; + this->networkBrokerId = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +NetworkBridgeFilter::~NetworkBridgeFilter() +{ + delete this->networkBrokerId; +} + +//////////////////////////////////////////////////////////////////////////////// +NetworkBridgeFilter* NetworkBridgeFilter::cloneDataStructure() const { + NetworkBridgeFilter* networkBridgeFilter = new NetworkBridgeFilter(); + + // Copy the data from the base class or classes + networkBridgeFilter->copyDataStructure( this ); + + return networkBridgeFilter; +} + +//////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilter::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const NetworkBridgeFilter* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "NetworkBridgeFilter::copyDataStructure - src is NULL or invalid" ); + } + this->setNetworkTTL( srcPtr->getNetworkTTL() ); + if( srcPtr->getNetworkBrokerId() != NULL ) { + this->setNetworkBrokerId( + dynamic_cast( + srcPtr->getNetworkBrokerId()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char NetworkBridgeFilter::getDataStructureType() const { + return NetworkBridgeFilter::ID_NETWORKBRIDGEFILTER; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string NetworkBridgeFilter::toString() const { + + ostringstream stream; + + stream << "Begin Class = NetworkBridgeFilter" << std::endl; + stream << " Value of NetworkBridgeFilter::ID_NETWORKBRIDGEFILTER = 91" << std::endl; + stream << " Value of NetworkTTL = " << this->getNetworkTTL() << std::endl; + stream << " Value of NetworkBrokerId is Below:" << std::endl; + if( this->getNetworkBrokerId() != NULL ) { + stream << this->getNetworkBrokerId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << BaseDataStructure::toString(); + stream << "End Class = NetworkBridgeFilter" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool NetworkBridgeFilter::equals( const DataStructure* value ) const { + const NetworkBridgeFilter* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getNetworkTTL() != valuePtr->getNetworkTTL() ) { + return false; + } + if( this->getNetworkBrokerId() != NULL ) { + if( !this->getNetworkBrokerId()->equals( valuePtr->getNetworkBrokerId() ) ) { + return false; + } + } else if( valuePtr->getNetworkBrokerId() != NULL ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +int NetworkBridgeFilter::getNetworkTTL() const { + return networkTTL; +} + +//////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilter::setNetworkTTL(int networkTTL ) { + this->networkTTL = networkTTL; +} + +//////////////////////////////////////////////////////////////////////////////// +const BrokerId* NetworkBridgeFilter::getNetworkBrokerId() const { + return networkBrokerId; +} + +//////////////////////////////////////////////////////////////////////////////// +BrokerId* NetworkBridgeFilter::getNetworkBrokerId() { + return networkBrokerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void NetworkBridgeFilter::setNetworkBrokerId(BrokerId* networkBrokerId ) { + this->networkBrokerId = networkBrokerId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_NETWORKBRIDGEFILTER_H_ +#define _ACTIVEMQ_COMMANDS_NETWORKBRIDGEFILTER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for NetworkBridgeFilter + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API NetworkBridgeFilter : public BaseDataStructure + { + protected: + + int networkTTL; + BrokerId* networkBrokerId; + + public: + + const static unsigned char ID_NETWORKBRIDGEFILTER = 91; + + public: + + NetworkBridgeFilter(); + virtual ~NetworkBridgeFilter(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual NetworkBridgeFilter* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual int getNetworkTTL() const; + virtual void setNetworkTTL( int networkTTL ); + + virtual const BrokerId* getNetworkBrokerId() const; + virtual BrokerId* getNetworkBrokerId(); + virtual void setNetworkBrokerId( BrokerId* networkBrokerId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_NETWORKBRIDGEFILTER_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/NetworkBridgeFilter.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 PartialCommand + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +PartialCommand::PartialCommand() +{ + this->commandId = 0; +} + +//////////////////////////////////////////////////////////////////////////////// +PartialCommand::~PartialCommand() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +PartialCommand* PartialCommand::cloneDataStructure() const { + PartialCommand* partialCommand = new PartialCommand(); + + // Copy the data from the base class or classes + partialCommand->copyDataStructure( this ); + + return partialCommand; +} + +//////////////////////////////////////////////////////////////////////////////// +void PartialCommand::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const PartialCommand* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "PartialCommand::copyDataStructure - src is NULL or invalid" ); + } + this->setCommandId( srcPtr->getCommandId() ); + this->setData( srcPtr->getData() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char PartialCommand::getDataStructureType() const { + return PartialCommand::ID_PARTIALCOMMAND; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string PartialCommand::toString() const { + + ostringstream stream; + + stream << "Begin Class = PartialCommand" << std::endl; + stream << " Value of PartialCommand::ID_PARTIALCOMMAND = 60" << std::endl; + stream << " Value of CommandId = " << this->getCommandId() << std::endl; + for( size_t idata = 0; idata < this->getData().size(); ++idata ) { + stream << " Value of Data[" << idata << "] = " << this->getData()[idata] << std::endl; + } + stream << BaseDataStructure::toString(); + stream << "End Class = PartialCommand" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool PartialCommand::equals( const DataStructure* value ) const { + const PartialCommand* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getCommandId() != valuePtr->getCommandId() ) { + return false; + } + for( size_t idata = 0; idata < this->getData().size(); ++idata ) { + if( this->getData()[idata] != valuePtr->getData()[idata] ) { + return false; + } + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +int PartialCommand::getCommandId() const { + return commandId; +} + +//////////////////////////////////////////////////////////////////////////////// +void PartialCommand::setCommandId(int commandId ) { + this->commandId = commandId; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::vector& PartialCommand::getData() const { + return data; +} + +//////////////////////////////////////////////////////////////////////////////// +std::vector& PartialCommand::getData() { + return data; +} + +//////////////////////////////////////////////////////////////////////////////// +void PartialCommand::setData(const std::vector& data ) { + this->data = data; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,108 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_PARTIALCOMMAND_H_ +#define _ACTIVEMQ_COMMANDS_PARTIALCOMMAND_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for PartialCommand + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API PartialCommand : public BaseDataStructure + { + protected: + + int commandId; + std::vector data; + + public: + + const static unsigned char ID_PARTIALCOMMAND = 60; + + public: + + PartialCommand(); + virtual ~PartialCommand(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual PartialCommand* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual int getCommandId() const; + virtual void setCommandId( int commandId ); + + virtual const std::vector& getData() const; + virtual std::vector& getData(); + virtual void setData( const std::vector& data ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_PARTIALCOMMAND_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/PartialCommand.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 ProducerAck + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +ProducerAck::ProducerAck() +{ + this->producerId = NULL; + this->size = 0; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerAck::~ProducerAck() +{ + delete this->producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerAck* ProducerAck::cloneDataStructure() const { + ProducerAck* producerAck = new ProducerAck(); + + // Copy the data from the base class or classes + producerAck->copyDataStructure( this ); + + return producerAck; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerAck::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseCommand::copyDataStructure( src ); + + const ProducerAck* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "ProducerAck::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getProducerId() != NULL ) { + this->setProducerId( + dynamic_cast( + srcPtr->getProducerId()->cloneDataStructure() ) ); + } + this->setSize( srcPtr->getSize() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char ProducerAck::getDataStructureType() const { + return ProducerAck::ID_PRODUCERACK; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string ProducerAck::toString() const { + + ostringstream stream; + + stream << "Begin Class = ProducerAck" << std::endl; + stream << " Value of ProducerAck::ID_PRODUCERACK = 19" << std::endl; + stream << " Value of ProducerId is Below:" << std::endl; + if( this->getProducerId() != NULL ) { + stream << this->getProducerId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of Size = " << this->getSize() << std::endl; + stream << BaseCommand::toString(); + stream << "End Class = ProducerAck" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool ProducerAck::equals( const DataStructure* value ) const { + const ProducerAck* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getProducerId() != NULL ) { + if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) { + return false; + } + } else if( valuePtr->getProducerId() != NULL ) { + return false; + } + if( this->getSize() != valuePtr->getSize() ) { + return false; + } + if( !BaseCommand::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ProducerId* ProducerAck::getProducerId() const { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerId* ProducerAck::getProducerId() { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerAck::setProducerId(ProducerId* producerId ) { + this->producerId = producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +int ProducerAck::getSize() const { + return size; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerAck::setSize(int size ) { + this->size = size; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_PRODUCERACK_H_ +#define _ACTIVEMQ_COMMANDS_PRODUCERACK_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for ProducerAck + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API ProducerAck : public BaseCommand + { + protected: + + ProducerId* producerId; + int size; + + public: + + const static unsigned char ID_PRODUCERACK = 19; + + public: + + ProducerAck(); + virtual ~ProducerAck(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual ProducerAck* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual const ProducerId* getProducerId() const; + virtual ProducerId* getProducerId(); + virtual void setProducerId( ProducerId* producerId ); + + virtual int getSize() const; + virtual void setSize( int size ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_PRODUCERACK_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerAck.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,156 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 ProducerId + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +ProducerId::ProducerId() +{ + this->connectionId = ""; + this->value = 0; + this->sessionId = 0; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerId::~ProducerId() +{ +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerId* ProducerId::cloneDataStructure() const { + ProducerId* producerId = new ProducerId(); + + // Copy the data from the base class or classes + producerId->copyDataStructure( this ); + + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerId::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseDataStructure::copyDataStructure( src ); + + const ProducerId* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "ProducerId::copyDataStructure - src is NULL or invalid" ); + } + this->setConnectionId( srcPtr->getConnectionId() ); + this->setValue( srcPtr->getValue() ); + this->setSessionId( srcPtr->getSessionId() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char ProducerId::getDataStructureType() const { + return ProducerId::ID_PRODUCERID; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string ProducerId::toString() const { + + ostringstream stream; + + stream << "Begin Class = ProducerId" << std::endl; + stream << " Value of ProducerId::ID_PRODUCERID = 123" << std::endl; + stream << " Value of ConnectionId = " << this->getConnectionId() << std::endl; + stream << " Value of Value = " << this->getValue() << std::endl; + stream << " Value of SessionId = " << this->getSessionId() << std::endl; + stream << BaseDataStructure::toString(); + stream << "End Class = ProducerId" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool ProducerId::equals( const DataStructure* value ) const { + const ProducerId* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getConnectionId() != valuePtr->getConnectionId() ) { + return false; + } + if( this->getValue() != valuePtr->getValue() ) { + return false; + } + if( this->getSessionId() != valuePtr->getSessionId() ) { + return false; + } + if( !BaseDataStructure::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::string& ProducerId::getConnectionId() const { + return connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string& ProducerId::getConnectionId() { + return connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerId::setConnectionId(const std::string& connectionId ) { + this->connectionId = connectionId; +} + +//////////////////////////////////////////////////////////////////////////////// +long long ProducerId::getValue() const { + return value; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerId::setValue(long long value ) { + this->value = value; +} + +//////////////////////////////////////////////////////////////////////////////// +long long ProducerId::getSessionId() const { + return sessionId; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerId::setSessionId(long long sessionId ) { + this->sessionId = sessionId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,112 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_PRODUCERID_H_ +#define _ACTIVEMQ_COMMANDS_PRODUCERID_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for ProducerId + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API ProducerId : public BaseDataStructure + { + protected: + + std::string connectionId; + long long value; + long long sessionId; + + public: + + const static unsigned char ID_PRODUCERID = 123; + + public: + + ProducerId(); + virtual ~ProducerId(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual ProducerId* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual const std::string& getConnectionId() const; + virtual std::string& getConnectionId(); + virtual void setConnectionId( const std::string& connectionId ); + + virtual long long getValue() const; + virtual void setValue( long long value ); + + virtual long long getSessionId() const; + virtual void setSessionId( long long sessionId ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_PRODUCERID_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerId.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,249 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 ProducerInfo + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +ProducerInfo::ProducerInfo() +{ + this->producerId = NULL; + this->destination = NULL; + this->dispatchAsync = false; + this->windowSize = 0; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerInfo::~ProducerInfo() +{ + delete this->producerId; + delete this->destination; + for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) { + delete brokerPath[ibrokerPath]; + } +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerInfo* ProducerInfo::cloneDataStructure() const { + ProducerInfo* producerInfo = new ProducerInfo(); + + // Copy the data from the base class or classes + producerInfo->copyDataStructure( this ); + + return producerInfo; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseCommand::copyDataStructure( src ); + + const ProducerInfo* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "ProducerInfo::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getProducerId() != NULL ) { + this->setProducerId( + dynamic_cast( + srcPtr->getProducerId()->cloneDataStructure() ) ); + } + if( srcPtr->getDestination() != NULL ) { + this->setDestination( + dynamic_cast( + srcPtr->getDestination()->cloneDataStructure() ) ); + } + for( size_t ibrokerPath = 0; ibrokerPath < srcPtr->getBrokerPath().size(); ++ibrokerPath ) { + if( srcPtr->getBrokerPath()[ibrokerPath] != NULL ) { + this->getBrokerPath().push_back( + dynamic_cast( + srcPtr->getBrokerPath()[ibrokerPath]->cloneDataStructure() ) ); + } else { + this->getBrokerPath().push_back( NULL ); + } + } + this->setDispatchAsync( srcPtr->isDispatchAsync() ); + this->setWindowSize( srcPtr->getWindowSize() ); +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char ProducerInfo::getDataStructureType() const { + return ProducerInfo::ID_PRODUCERINFO; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string ProducerInfo::toString() const { + + ostringstream stream; + + stream << "Begin Class = ProducerInfo" << std::endl; + stream << " Value of ProducerInfo::ID_PRODUCERINFO = 6" << std::endl; + stream << " Value of ProducerId is Below:" << std::endl; + if( this->getProducerId() != NULL ) { + stream << this->getProducerId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << " Value of Destination is Below:" << std::endl; + if( this->getDestination() != NULL ) { + stream << this->getDestination()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) { + stream << " Value of BrokerPath[" << ibrokerPath << "] is Below:" << std::endl; + if( this->getBrokerPath()[ibrokerPath] != NULL ) { + stream << this->getBrokerPath()[ibrokerPath]->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + } + stream << " Value of DispatchAsync = " << this->isDispatchAsync() << std::endl; + stream << " Value of WindowSize = " << this->getWindowSize() << std::endl; + stream << BaseCommand::toString(); + stream << "End Class = ProducerInfo" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool ProducerInfo::equals( const DataStructure* value ) const { + const ProducerInfo* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getProducerId() != NULL ) { + if( !this->getProducerId()->equals( valuePtr->getProducerId() ) ) { + return false; + } + } else if( valuePtr->getProducerId() != NULL ) { + return false; + } + if( this->getDestination() != NULL ) { + if( !this->getDestination()->equals( valuePtr->getDestination() ) ) { + return false; + } + } else if( valuePtr->getDestination() != NULL ) { + return false; + } + for( size_t ibrokerPath = 0; ibrokerPath < this->getBrokerPath().size(); ++ibrokerPath ) { + if( this->getBrokerPath()[ibrokerPath] != NULL ) { + if( !this->getBrokerPath()[ibrokerPath]->equals( valuePtr->getBrokerPath()[ibrokerPath] ) ) { + return false; + } + } else if( valuePtr->getBrokerPath()[ibrokerPath] != NULL ) { + return false; + } + } + if( this->isDispatchAsync() != valuePtr->isDispatchAsync() ) { + return false; + } + if( this->getWindowSize() != valuePtr->getWindowSize() ) { + return false; + } + if( !BaseCommand::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const ProducerId* ProducerInfo::getProducerId() const { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +ProducerId* ProducerInfo::getProducerId() { + return producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::setProducerId(ProducerId* producerId ) { + this->producerId = producerId; +} + +//////////////////////////////////////////////////////////////////////////////// +const ActiveMQDestination* ProducerInfo::getDestination() const { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +ActiveMQDestination* ProducerInfo::getDestination() { + return destination; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::setDestination(ActiveMQDestination* destination ) { + this->destination = destination; +} + +//////////////////////////////////////////////////////////////////////////////// +const std::vector& ProducerInfo::getBrokerPath() const { + return brokerPath; +} + +//////////////////////////////////////////////////////////////////////////////// +std::vector& ProducerInfo::getBrokerPath() { + return brokerPath; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::setBrokerPath(const std::vector& brokerPath ) { + this->brokerPath = brokerPath; +} + +//////////////////////////////////////////////////////////////////////////////// +bool ProducerInfo::isDispatchAsync() const { + return dispatchAsync; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::setDispatchAsync(bool dispatchAsync ) { + this->dispatchAsync = dispatchAsync; +} + +//////////////////////////////////////////////////////////////////////////////// +int ProducerInfo::getWindowSize() const { + return windowSize; +} + +//////////////////////////////////////////////////////////////////////////////// +void ProducerInfo::setWindowSize(int windowSize ) { + this->windowSize = windowSize; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h Sun Jan 11 08:36:02 2009 @@ -0,0 +1,125 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_COMMANDS_PRODUCERINFO_H_ +#define _ACTIVEMQ_COMMANDS_PRODUCERINFO_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace commands{ + + /* + * + * Command and marshaling code for OpenWire format for ProducerInfo + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + * + */ + class AMQCPP_API ProducerInfo : public BaseCommand + { + protected: + + ProducerId* producerId; + ActiveMQDestination* destination; + std::vector brokerPath; + bool dispatchAsync; + int windowSize; + + public: + + const static unsigned char ID_PRODUCERINFO = 6; + + public: + + ProducerInfo(); + virtual ~ProducerInfo(); + + /** + * Get the unique identifier that this object and its own + * Marshaller share. + * @returns new DataStructure type copy. + */ + virtual unsigned char getDataStructureType() const; + + /** + * Clone this object and return a new instance that the + * caller now owns, this will be an exact copy of this one + * @returns new copy of this object. + */ + virtual ProducerInfo* cloneDataStructure() const; + + /** + * Copy the contents of the passed object into this object's + * members, overwriting any existing data. + * @param src - Source Object + */ + virtual void copyDataStructure( const DataStructure* src ); + + /** + * Returns a string containing the information for this DataStructure + * such as its type and value of its elements. + * @return formatted string useful for debugging. + */ + virtual std::string toString() const; + + /** + * Compares the DataStructure passed in to this one, and returns if + * they are equivalent. Equivalent here means that they are of the + * same type, and that each element of the objects are the same. + * @returns true if DataStructure's are Equal. + */ + virtual bool equals( const DataStructure* value ) const; + + virtual const ProducerId* getProducerId() const; + virtual ProducerId* getProducerId(); + virtual void setProducerId( ProducerId* producerId ); + + virtual const ActiveMQDestination* getDestination() const; + virtual ActiveMQDestination* getDestination(); + virtual void setDestination( ActiveMQDestination* destination ); + + virtual const std::vector& getBrokerPath() const; + virtual std::vector& getBrokerPath(); + virtual void setBrokerPath( const std::vector& brokerPath ); + + virtual bool isDispatchAsync() const; + virtual void setDispatchAsync( bool dispatchAsync ); + + virtual int getWindowSize() const; + virtual void setWindowSize( int windowSize ); + + }; + +}} + +#endif /*_ACTIVEMQ_COMMANDS_PRODUCERINFO_H_*/ + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/ProducerInfo.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp?rev=733487&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp Sun Jan 11 08:36:02 2009 @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include +#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 RemoveInfo + * + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes in the + * activemq-core module + * + */ +//////////////////////////////////////////////////////////////////////////////// +RemoveInfo::RemoveInfo() +{ + this->objectId = NULL; +} + +//////////////////////////////////////////////////////////////////////////////// +RemoveInfo::~RemoveInfo() +{ + delete this->objectId; +} + +//////////////////////////////////////////////////////////////////////////////// +RemoveInfo* RemoveInfo::cloneDataStructure() const { + RemoveInfo* removeInfo = new RemoveInfo(); + + // Copy the data from the base class or classes + removeInfo->copyDataStructure( this ); + + return removeInfo; +} + +//////////////////////////////////////////////////////////////////////////////// +void RemoveInfo::copyDataStructure( const DataStructure* src ) { + + // Copy the data of the base class or classes + BaseCommand::copyDataStructure( src ); + + const RemoveInfo* srcPtr = dynamic_cast( src ); + + if( srcPtr == NULL || src == NULL ) { + + throw decaf::lang::exceptions::NullPointerException( + __FILE__, __LINE__, + "RemoveInfo::copyDataStructure - src is NULL or invalid" ); + } + if( srcPtr->getObjectId() != NULL ) { + this->setObjectId( + dynamic_cast( + srcPtr->getObjectId()->cloneDataStructure() ) ); + } +} + +//////////////////////////////////////////////////////////////////////////////// +unsigned char RemoveInfo::getDataStructureType() const { + return RemoveInfo::ID_REMOVEINFO; +} + +//////////////////////////////////////////////////////////////////////////////// +std::string RemoveInfo::toString() const { + + ostringstream stream; + + stream << "Begin Class = RemoveInfo" << std::endl; + stream << " Value of RemoveInfo::ID_REMOVEINFO = 12" << std::endl; + stream << " Value of ObjectId is Below:" << std::endl; + if( this->getObjectId() != NULL ) { + stream << this->getObjectId()->toString() << std::endl; + } else { + stream << " Object is NULL" << std::endl; + } + stream << BaseCommand::toString(); + stream << "End Class = RemoveInfo" << std::endl; + + return stream.str(); +} + +//////////////////////////////////////////////////////////////////////////////// +bool RemoveInfo::equals( const DataStructure* value ) const { + const RemoveInfo* valuePtr = dynamic_cast( value ); + + if( valuePtr == NULL || value == NULL ) { + return false; + } + if( this->getObjectId() != NULL ) { + if( !this->getObjectId()->equals( valuePtr->getObjectId() ) ) { + return false; + } + } else if( valuePtr->getObjectId() != NULL ) { + return false; + } + if( !BaseCommand::equals( value ) ) { + return false; + } + return true; +} + +//////////////////////////////////////////////////////////////////////////////// +const DataStructure* RemoveInfo::getObjectId() const { + return objectId; +} + +//////////////////////////////////////////////////////////////////////////////// +DataStructure* RemoveInfo::getObjectId() { + return objectId; +} + +//////////////////////////////////////////////////////////////////////////////// +void RemoveInfo::setObjectId(DataStructure* objectId ) { + this->objectId = objectId; +} + Propchange: activemq/activemq-cpp/trunk/src/main/activemq/commands/RemoveInfo.cpp ------------------------------------------------------------------------------ svn:eol-style = native