You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2006/10/02 16:30:22 UTC
svn commit: r452053 [4/17] - in
/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src:
main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/
main/activemq/connector/openwire/marshal/
main/activemq/connector/openwire/marshal/V2/...
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerError.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerError.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerError.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerError.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,127 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_BROKERERROR_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERERROR_H_
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+
+#include <string>
+#include <vector>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /**
+ * This class represents an Exception sent from the Broker. The Broker
+ * sends java Throwables, so we must mimic its structure here.
+ */
+ class BrokerError : public BaseCommand
+ {
+ public:
+
+ struct StackTraceElement
+ {
+ std::string ClassName;
+ std::string FileName;
+ std::string MethodName;
+ int LineNumber;
+ };
+
+ public:
+
+ BrokerError() {}
+ virtual ~BrokerError() {}
+
+ /**
+ * Gets the string holding the error message
+ * @returns String Message
+ */
+ virtual const std::string& getMessage() const {
+ return message;
+ }
+
+ /**
+ * Sets the string that contains the error Message
+ * @param message - String Error Message
+ */
+ virtual void setMessage( const std::string& message ) {
+ this->message = message;
+ }
+
+ /**
+ * Gets the string holding the Exception Class name
+ * @returns Exception Class name
+ */
+ virtual const std::string& getExceptionClass() const {
+ return exceptionClass;
+ }
+
+ /**
+ * Sets the string that contains the Exception Class name
+ * @param exceptionClass - String Exception Class name
+ */
+ virtual void setExceptionClass( const std::string& exceptionClass ) {
+ this->exceptionClass = exceptionClass;
+ }
+
+ /**
+ * Gets the Broker Error that caused this exception
+ * @returns Broker Error Pointer
+ */
+ virtual BrokerError* getCause() const {
+ return cause;
+ }
+
+ /**
+ * Sets the Broker Error that caused this exception
+ * @param cause - Broker Error
+ */
+ virtual void setCause( BrokerError* cause ) {
+ this->cause = cause;
+ }
+
+ /**
+ * Gets the Stack Trace Elemtns for the Exception
+ * @returns Stack Trace Elements
+ */
+ virtual const std::vector<StackTraceElement*>& getStackTraceElements() const {
+ return stackTraceElements;
+ }
+
+ /**
+ * Sets the Stack Trace Elements for this Exception
+ * @param stackTraceElements - Stack Trace Elements
+ */
+ virtual void setCause( const std::vector<StackTraceElement*>& stackTraceElements ) {
+ this->stackTraceElements = stackTraceElements;
+ }
+
+ private:
+
+ std::string message;
+ std::string exceptionClass;
+ std::vector<StackTraceElement*> stackTraceElements;
+ BrokerError* cause;
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERERROR_H_*/
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerError.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/BrokerId.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for BrokerId
+ *
+ *
+ * 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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+BrokerId::BrokerId()
+{
+ this->value = "";
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BrokerId::~BrokerId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char BrokerId::getDataStructureType() const
+{
+ return BrokerId::ID_BROKERID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& BrokerId::getValue() const {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& BrokerId::getValue() {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerId::setValue(const std::string& value ) {
+ this->value = value;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,70 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_BROKERID_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseDataStructure.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 BrokerId : public BaseDataStructure
+ {
+ protected:
+
+ std::string value;
+
+ public:
+
+ const static unsigned char ID_BROKERID = 124;
+
+ public:
+
+ BrokerId();
+ virtual ~BrokerId();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const std::string& getValue() const;
+ virtual std::string& getValue();
+ virtual void setValue( const std::string& value );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERID_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerId.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/BrokerInfo.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for BrokerInfo
+ *
+ *
+ * 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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+BrokerInfo::BrokerInfo()
+{
+ this->brokerId = NULL;
+ this->brokerURL = "";
+ this->brokerName = "";
+ this->slaveBroker = false;
+ this->masterBroker = false;
+ this->faultTolerantConfiguration = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BrokerInfo::~BrokerInfo()
+{
+ delete this->brokerId;
+ for( size_t ipeerBrokerInfos = 0; ipeerBrokerInfos < peerBrokerInfos.size(); ++ipeerBrokerInfos ) {
+ delete peerBrokerInfos[ipeerBrokerInfos];
+ }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char BrokerInfo::getDataStructureType() const
+{
+ return BrokerInfo::ID_BROKERINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const BrokerId* BrokerInfo::getBrokerId() const {
+ return brokerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BrokerId* BrokerInfo::getBrokerId() {
+ return brokerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setBrokerId(BrokerId* brokerId ) {
+ this->brokerId = brokerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& BrokerInfo::getBrokerURL() const {
+ return brokerURL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& BrokerInfo::getBrokerURL() {
+ return brokerURL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setBrokerURL(const std::string& brokerURL ) {
+ this->brokerURL = brokerURL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerInfo*> BrokerInfo::getPeerBrokerInfos() const {
+ return peerBrokerInfos;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerInfo*> BrokerInfo::getPeerBrokerInfos() {
+ return peerBrokerInfos;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setPeerBrokerInfos(std::vector<BrokerInfo*> peerBrokerInfos ) {
+ this->peerBrokerInfos = peerBrokerInfos;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& BrokerInfo::getBrokerName() const {
+ return brokerName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& BrokerInfo::getBrokerName() {
+ return brokerName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setBrokerName(const std::string& brokerName ) {
+ this->brokerName = brokerName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool BrokerInfo::getSlaveBroker() const {
+ return slaveBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool BrokerInfo::getSlaveBroker() {
+ return slaveBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setSlaveBroker(bool slaveBroker ) {
+ this->slaveBroker = slaveBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool BrokerInfo::getMasterBroker() const {
+ return masterBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool BrokerInfo::getMasterBroker() {
+ return masterBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setMasterBroker(bool masterBroker ) {
+ this->masterBroker = masterBroker;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool BrokerInfo::getFaultTolerantConfiguration() const {
+ return faultTolerantConfiguration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool BrokerInfo::getFaultTolerantConfiguration() {
+ return faultTolerantConfiguration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void BrokerInfo::setFaultTolerantConfiguration(bool faultTolerantConfiguration ) {
+ this->faultTolerantConfiguration = faultTolerantConfiguration;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,102 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_BROKERINFO_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERINFO_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/BrokerId.h>
+#include <activemq/connector/openwire/commands/BrokerInfo.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 BrokerInfo : public BaseCommand
+ {
+ protected:
+
+ BrokerId* brokerId;
+ std::string brokerURL;
+ std::vector<BrokerInfo*> peerBrokerInfos;
+ std::string brokerName;
+ bool slaveBroker;
+ bool masterBroker;
+ bool faultTolerantConfiguration;
+
+ public:
+
+ const static unsigned char ID_BROKERINFO = 2;
+
+ public:
+
+ BrokerInfo();
+ virtual ~BrokerInfo();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const BrokerId* getBrokerId() const;
+ virtual BrokerId* getBrokerId();
+ virtual void setBrokerId( BrokerId* brokerId );
+
+ virtual const std::string& getBrokerURL() const;
+ virtual std::string& getBrokerURL();
+ virtual void setBrokerURL( const std::string& brokerURL );
+
+ virtual const std::vector<BrokerInfo*> getPeerBrokerInfos() const;
+ virtual std::vector<BrokerInfo*> getPeerBrokerInfos();
+ virtual void setPeerBrokerInfos( std::vector<BrokerInfo*> peerBrokerInfos );
+
+ virtual const std::string& getBrokerName() const;
+ virtual std::string& getBrokerName();
+ virtual void setBrokerName( const std::string& brokerName );
+
+ virtual const bool getSlaveBroker() const;
+ virtual bool getSlaveBroker();
+ virtual void setSlaveBroker( bool slaveBroker );
+
+ virtual const bool getMasterBroker() const;
+ virtual bool getMasterBroker();
+ virtual void setMasterBroker( bool masterBroker );
+
+ virtual const bool getFaultTolerantConfiguration() const;
+ virtual bool getFaultTolerantConfiguration();
+ virtual void setFaultTolerantConfiguration( bool faultTolerantConfiguration );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_BROKERINFO_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/BrokerInfo.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,130 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConnectionControl.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConnectionControl
+ *
+ *
+ * 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
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionControl::ConnectionControl()
+{
+ this->close = false;
+ this->exit = false;
+ this->faultTolerant = false;
+ this->resume = false;
+ this->suspend = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionControl::~ConnectionControl()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionControl::getDataStructureType() const
+{
+ return ConnectionControl::ID_CONNECTIONCONTROL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionControl::getClose() const {
+ return close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionControl::getClose() {
+ return close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionControl::setClose(bool close ) {
+ this->close = close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionControl::getExit() const {
+ return exit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionControl::getExit() {
+ return exit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionControl::setExit(bool exit ) {
+ this->exit = exit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionControl::getFaultTolerant() const {
+ return faultTolerant;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionControl::getFaultTolerant() {
+ return faultTolerant;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionControl::setFaultTolerant(bool faultTolerant ) {
+ this->faultTolerant = faultTolerant;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionControl::getResume() const {
+ return resume;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionControl::getResume() {
+ return resume;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionControl::setResume(bool resume ) {
+ this->resume = resume;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionControl::getSuspend() const {
+ return suspend;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionControl::getSuspend() {
+ return suspend;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionControl::setSuspend(bool suspend ) {
+ this->suspend = suspend;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,90 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONCONTROL_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONCONTROL_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConnectionControl : public BaseCommand
+ {
+ protected:
+
+ bool close;
+ bool exit;
+ bool faultTolerant;
+ bool resume;
+ bool suspend;
+
+ public:
+
+ const static unsigned char ID_CONNECTIONCONTROL = 18;
+
+ public:
+
+ ConnectionControl();
+ virtual ~ConnectionControl();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const bool getClose() const;
+ virtual bool getClose();
+ virtual void setClose( bool close );
+
+ virtual const bool getExit() const;
+ virtual bool getExit();
+ virtual void setExit( bool exit );
+
+ virtual const bool getFaultTolerant() const;
+ virtual bool getFaultTolerant();
+ virtual void setFaultTolerant( bool faultTolerant );
+
+ virtual const bool getResume() const;
+ virtual bool getResume();
+ virtual void setResume( bool resume );
+
+ virtual const bool getSuspend() const;
+ virtual bool getSuspend();
+ virtual void setSuspend( bool suspend );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONCONTROL_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionControl.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConnectionError.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConnectionError
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionError::ConnectionError()
+{
+ this->exception = NULL;
+ this->connectionId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionError::~ConnectionError()
+{
+ delete this->exception;
+ delete this->connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionError::getDataStructureType() const
+{
+ return ConnectionError::ID_CONNECTIONERROR;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const BrokerError* ConnectionError::getException() const {
+ return exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BrokerError* ConnectionError::getException() {
+ return exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionError::setException(BrokerError* exception ) {
+ this->exception = exception;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* ConnectionError::getConnectionId() const {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* ConnectionError::getConnectionId() {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionError::setConnectionId(ConnectionId* connectionId ) {
+ this->connectionId = connectionId;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,77 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONERROR_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONERROR_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/BrokerError.h>
+#include <activemq/connector/openwire/commands/ConnectionId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConnectionError : public BaseCommand
+ {
+ protected:
+
+ BrokerError* exception;
+ ConnectionId* connectionId;
+
+ public:
+
+ const static unsigned char ID_CONNECTIONERROR = 16;
+
+ public:
+
+ ConnectionError();
+ virtual ~ConnectionError();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const BrokerError* getException() const;
+ virtual BrokerError* getException();
+ virtual void setException( BrokerError* exception );
+
+ virtual const ConnectionId* getConnectionId() const;
+ virtual ConnectionId* getConnectionId();
+ virtual void setConnectionId( ConnectionId* connectionId );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONERROR_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionError.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConnectionId.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConnectionId
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId::ConnectionId()
+{
+ this->value = "";
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId::~ConnectionId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionId::getDataStructureType() const
+{
+ return ConnectionId::ID_CONNECTIONID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionId::getValue() const {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionId::getValue() {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionId::setValue(const std::string& value ) {
+ this->value = value;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,70 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONID_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseDataStructure.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConnectionId : public BaseDataStructure
+ {
+ protected:
+
+ std::string value;
+
+ public:
+
+ const static unsigned char ID_CONNECTIONID = 120;
+
+ public:
+
+ ConnectionId();
+ virtual ~ConnectionId();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const std::string& getValue() const;
+ virtual std::string& getValue();
+ virtual void setValue( const std::string& value );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONID_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionId.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConnectionInfo.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConnectionInfo
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConnectionInfo::ConnectionInfo()
+{
+ this->connectionId = NULL;
+ this->clientId = "";
+ this->password = "";
+ this->userName = "";
+ this->brokerMasterConnector = false;
+ this->manageable = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionInfo::~ConnectionInfo()
+{
+ delete this->connectionId;
+ for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+ delete brokerPath[ibrokerPath];
+ }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConnectionInfo::getDataStructureType() const
+{
+ return ConnectionInfo::ID_CONNECTIONINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* ConnectionInfo::getConnectionId() const {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* ConnectionInfo::getConnectionId() {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setConnectionId(ConnectionId* connectionId ) {
+ this->connectionId = connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getClientId() const {
+ return clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getClientId() {
+ return clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setClientId(const std::string& clientId ) {
+ this->clientId = clientId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getPassword() const {
+ return password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getPassword() {
+ return password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setPassword(const std::string& password ) {
+ this->password = password;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConnectionInfo::getUserName() const {
+ return userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConnectionInfo::getUserName() {
+ return userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setUserName(const std::string& userName ) {
+ this->userName = userName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*> ConnectionInfo::getBrokerPath() const {
+ return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*> ConnectionInfo::getBrokerPath() {
+ return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setBrokerPath(std::vector<BrokerId*> brokerPath ) {
+ this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionInfo::getBrokerMasterConnector() const {
+ return brokerMasterConnector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::getBrokerMasterConnector() {
+ return brokerMasterConnector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setBrokerMasterConnector(bool brokerMasterConnector ) {
+ this->brokerMasterConnector = brokerMasterConnector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConnectionInfo::getManageable() const {
+ return manageable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConnectionInfo::getManageable() {
+ return manageable;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConnectionInfo::setManageable(bool manageable ) {
+ this->manageable = manageable;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,102 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONINFO_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONINFO_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConnectionId.h>
+#include <activemq/connector/openwire/commands/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConnectionInfo : public BaseCommand
+ {
+ protected:
+
+ ConnectionId* connectionId;
+ std::string clientId;
+ std::string password;
+ std::string userName;
+ std::vector<BrokerId*> brokerPath;
+ bool brokerMasterConnector;
+ bool manageable;
+
+ public:
+
+ const static unsigned char ID_CONNECTIONINFO = 3;
+
+ public:
+
+ ConnectionInfo();
+ virtual ~ConnectionInfo();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const ConnectionId* getConnectionId() const;
+ virtual ConnectionId* getConnectionId();
+ virtual void setConnectionId( ConnectionId* connectionId );
+
+ virtual const std::string& getClientId() const;
+ virtual std::string& getClientId();
+ virtual void setClientId( const std::string& clientId );
+
+ virtual const std::string& getPassword() const;
+ virtual std::string& getPassword();
+ virtual void setPassword( const std::string& password );
+
+ virtual const std::string& getUserName() const;
+ virtual std::string& getUserName();
+ virtual void setUserName( const std::string& userName );
+
+ virtual const std::vector<BrokerId*> getBrokerPath() const;
+ virtual std::vector<BrokerId*> getBrokerPath();
+ virtual void setBrokerPath( std::vector<BrokerId*> brokerPath );
+
+ virtual const bool getBrokerMasterConnector() const;
+ virtual bool getBrokerMasterConnector();
+ virtual void setBrokerMasterConnector( bool brokerMasterConnector );
+
+ virtual const bool getManageable() const;
+ virtual bool getManageable();
+ virtual void setManageable( bool manageable );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONNECTIONINFO_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConnectionInfo.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.cpp Mon Oct 2 07:30:10 2006
@@ -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.
+ */
+#include <activemq/connector/openwire/commands/ConsumerControl.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConsumerControl
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerControl::ConsumerControl()
+{
+ this->close = false;
+ this->consumerId = NULL;
+ this->prefetch = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerControl::~ConsumerControl()
+{
+ delete this->consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerControl::getDataStructureType() const
+{
+ return ConsumerControl::ID_CONSUMERCONTROL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerControl::getClose() const {
+ return close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerControl::getClose() {
+ return close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setClose(bool close ) {
+ this->close = close;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* ConsumerControl::getConsumerId() const {
+ return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* ConsumerControl::getConsumerId() {
+ return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setConsumerId(ConsumerId* consumerId ) {
+ this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int ConsumerControl::getPrefetch() const {
+ return prefetch;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerControl::getPrefetch() {
+ return prefetch;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerControl::setPrefetch(int prefetch ) {
+ this->prefetch = prefetch;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,81 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERCONTROL_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERCONTROL_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConsumerControl : public BaseCommand
+ {
+ protected:
+
+ bool close;
+ ConsumerId* consumerId;
+ int prefetch;
+
+ public:
+
+ const static unsigned char ID_CONSUMERCONTROL = 17;
+
+ public:
+
+ ConsumerControl();
+ virtual ~ConsumerControl();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const bool getClose() const;
+ virtual bool getClose();
+ virtual void setClose( bool close );
+
+ virtual const ConsumerId* getConsumerId() const;
+ virtual ConsumerId* getConsumerId();
+ virtual void setConsumerId( ConsumerId* consumerId );
+
+ virtual const int getPrefetch() const;
+ virtual int getPrefetch();
+ virtual void setPrefetch( int prefetch );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERCONTROL_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerControl.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConsumerId
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId::ConsumerId()
+{
+ this->connectionId = "";
+ this->sessionId = 0;
+ this->value = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId::~ConsumerId()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerId::getDataStructureType() const
+{
+ return ConsumerId::ID_CONSUMERID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerId::getConnectionId() const {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerId::getConnectionId() {
+ return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setConnectionId(const std::string& connectionId ) {
+ this->connectionId = connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long ConsumerId::getSessionId() const {
+ return sessionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long ConsumerId::getSessionId() {
+ return sessionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setSessionId(long long sessionId ) {
+ this->sessionId = sessionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long ConsumerId::getValue() const {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long ConsumerId::getValue() {
+ return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerId::setValue(long long value ) {
+ this->value = value;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.h Mon Oct 2 07:30:10 2006
@@ -0,0 +1,80 @@
+/*
+ * 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_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERID_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseDataStructure.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConsumerId : public BaseDataStructure
+ {
+ protected:
+
+ std::string connectionId;
+ long long sessionId;
+ long long value;
+
+ public:
+
+ const static unsigned char ID_CONSUMERID = 122;
+
+ public:
+
+ ConsumerId();
+ virtual ~ConsumerId();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const std::string& getConnectionId() const;
+ virtual std::string& getConnectionId();
+ virtual void setConnectionId( const std::string& connectionId );
+
+ virtual const long long getSessionId() const;
+ virtual long long getSessionId();
+ virtual void setSessionId( long long sessionId );
+
+ virtual const long long getValue() const;
+ virtual long long getValue();
+ virtual void setValue( long long value );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERID_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerId.h
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.cpp Mon Oct 2 07:30:10 2006
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/ConsumerInfo.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ * Command and marshalling code for OpenWire format for ConsumerInfo
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Java Classes in the
+ * activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+ConsumerInfo::ConsumerInfo()
+{
+ this->consumerId = NULL;
+ this->browser = false;
+ this->destination = NULL;
+ this->prefetchSize = 0;
+ this->maximumPendingMessageLimit = 0;
+ this->dispatchAsync = false;
+ this->selector = "";
+ this->subcriptionName = "";
+ this->noLocal = false;
+ this->exclusive = false;
+ this->retroactive = false;
+ this->priority = 0;
+ this->additionalPredicate = NULL;
+ this->networkSubscription = false;
+ this->optimizedAcknowledge = false;
+ this->noRangeAcks = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerInfo::~ConsumerInfo()
+{
+ delete this->consumerId;
+ delete this->destination;
+ for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+ delete brokerPath[ibrokerPath];
+ }
+ delete this->additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char ConsumerInfo::getDataStructureType() const
+{
+ return ConsumerInfo::ID_CONSUMERINFO;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* ConsumerInfo::getConsumerId() const {
+ return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* ConsumerInfo::getConsumerId() {
+ return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setConsumerId(ConsumerId* consumerId ) {
+ this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getBrowser() const {
+ return browser;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getBrowser() {
+ return browser;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setBrowser(bool browser ) {
+ this->browser = browser;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* ConsumerInfo::getDestination() const {
+ return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* ConsumerInfo::getDestination() {
+ return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setDestination(ActiveMQDestination* destination ) {
+ this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int ConsumerInfo::getPrefetchSize() const {
+ return prefetchSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerInfo::getPrefetchSize() {
+ return prefetchSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setPrefetchSize(int prefetchSize ) {
+ this->prefetchSize = prefetchSize;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int ConsumerInfo::getMaximumPendingMessageLimit() const {
+ return maximumPendingMessageLimit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int ConsumerInfo::getMaximumPendingMessageLimit() {
+ return maximumPendingMessageLimit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit ) {
+ this->maximumPendingMessageLimit = maximumPendingMessageLimit;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getDispatchAsync() const {
+ return dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getDispatchAsync() {
+ return dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setDispatchAsync(bool dispatchAsync ) {
+ this->dispatchAsync = dispatchAsync;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerInfo::getSelector() const {
+ return selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerInfo::getSelector() {
+ return selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setSelector(const std::string& selector ) {
+ this->selector = selector;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& ConsumerInfo::getSubcriptionName() const {
+ return subcriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& ConsumerInfo::getSubcriptionName() {
+ return subcriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setSubcriptionName(const std::string& subcriptionName ) {
+ this->subcriptionName = subcriptionName;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getNoLocal() const {
+ return noLocal;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getNoLocal() {
+ return noLocal;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNoLocal(bool noLocal ) {
+ this->noLocal = noLocal;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getExclusive() const {
+ return exclusive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getExclusive() {
+ return exclusive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setExclusive(bool exclusive ) {
+ this->exclusive = exclusive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getRetroactive() const {
+ return retroactive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getRetroactive() {
+ return retroactive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setRetroactive(bool retroactive ) {
+ this->retroactive = retroactive;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const char ConsumerInfo::getPriority() const {
+ return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+char ConsumerInfo::getPriority() {
+ return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setPriority(char priority ) {
+ this->priority = priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*> ConsumerInfo::getBrokerPath() const {
+ return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*> ConsumerInfo::getBrokerPath() {
+ return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setBrokerPath(std::vector<BrokerId*> brokerPath ) {
+ this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const BooleanExpression* ConsumerInfo::getAdditionalPredicate() const {
+ return additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+BooleanExpression* ConsumerInfo::getAdditionalPredicate() {
+ return additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setAdditionalPredicate(BooleanExpression* additionalPredicate ) {
+ this->additionalPredicate = additionalPredicate;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getNetworkSubscription() const {
+ return networkSubscription;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getNetworkSubscription() {
+ return networkSubscription;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNetworkSubscription(bool networkSubscription ) {
+ this->networkSubscription = networkSubscription;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getOptimizedAcknowledge() const {
+ return optimizedAcknowledge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getOptimizedAcknowledge() {
+ return optimizedAcknowledge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setOptimizedAcknowledge(bool optimizedAcknowledge ) {
+ this->optimizedAcknowledge = optimizedAcknowledge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool ConsumerInfo::getNoRangeAcks() const {
+ return noRangeAcks;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool ConsumerInfo::getNoRangeAcks() {
+ return noRangeAcks;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void ConsumerInfo::setNoRangeAcks(bool noRangeAcks ) {
+ this->noRangeAcks = noRangeAcks;
+}
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.h Mon Oct 2 07:30:10 2006
@@ -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.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERINFO_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERINFO_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/BrokerId.h>
+#include <activemq/connector/openwire/commands/BooleanExpression.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+ /*
+ *
+ * Command and marshalling code for OpenWire format for ${className}
+ *
+ *
+ * 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 ConsumerInfo : public BaseCommand
+ {
+ protected:
+
+ ConsumerId* consumerId;
+ bool browser;
+ ActiveMQDestination* destination;
+ int prefetchSize;
+ int maximumPendingMessageLimit;
+ bool dispatchAsync;
+ std::string selector;
+ std::string subcriptionName;
+ bool noLocal;
+ bool exclusive;
+ bool retroactive;
+ char priority;
+ std::vector<BrokerId*> brokerPath;
+ BooleanExpression* additionalPredicate;
+ bool networkSubscription;
+ bool optimizedAcknowledge;
+ bool noRangeAcks;
+
+ public:
+
+ const static unsigned char ID_CONSUMERINFO = 5;
+
+ public:
+
+ ConsumerInfo();
+ virtual ~ConsumerInfo();
+
+ virtual unsigned char getDataStructureType() const;
+ virtual const ConsumerId* getConsumerId() const;
+ virtual ConsumerId* getConsumerId();
+ virtual void setConsumerId( ConsumerId* consumerId );
+
+ virtual const bool getBrowser() const;
+ virtual bool getBrowser();
+ virtual void setBrowser( bool browser );
+
+ virtual const ActiveMQDestination* getDestination() const;
+ virtual ActiveMQDestination* getDestination();
+ virtual void setDestination( ActiveMQDestination* destination );
+
+ virtual const int getPrefetchSize() const;
+ virtual int getPrefetchSize();
+ virtual void setPrefetchSize( int prefetchSize );
+
+ virtual const int getMaximumPendingMessageLimit() const;
+ virtual int getMaximumPendingMessageLimit();
+ virtual void setMaximumPendingMessageLimit( int maximumPendingMessageLimit );
+
+ virtual const bool getDispatchAsync() const;
+ virtual bool getDispatchAsync();
+ virtual void setDispatchAsync( bool dispatchAsync );
+
+ virtual const std::string& getSelector() const;
+ virtual std::string& getSelector();
+ virtual void setSelector( const std::string& selector );
+
+ virtual const std::string& getSubcriptionName() const;
+ virtual std::string& getSubcriptionName();
+ virtual void setSubcriptionName( const std::string& subcriptionName );
+
+ virtual const bool getNoLocal() const;
+ virtual bool getNoLocal();
+ virtual void setNoLocal( bool noLocal );
+
+ virtual const bool getExclusive() const;
+ virtual bool getExclusive();
+ virtual void setExclusive( bool exclusive );
+
+ virtual const bool getRetroactive() const;
+ virtual bool getRetroactive();
+ virtual void setRetroactive( bool retroactive );
+
+ virtual const char getPriority() const;
+ virtual char getPriority();
+ virtual void setPriority( char priority );
+
+ virtual const std::vector<BrokerId*> getBrokerPath() const;
+ virtual std::vector<BrokerId*> getBrokerPath();
+ virtual void setBrokerPath( std::vector<BrokerId*> brokerPath );
+
+ virtual const BooleanExpression* getAdditionalPredicate() const;
+ virtual BooleanExpression* getAdditionalPredicate();
+ virtual void setAdditionalPredicate( BooleanExpression* additionalPredicate );
+
+ virtual const bool getNetworkSubscription() const;
+ virtual bool getNetworkSubscription();
+ virtual void setNetworkSubscription( bool networkSubscription );
+
+ virtual const bool getOptimizedAcknowledge() const;
+ virtual bool getOptimizedAcknowledge();
+ virtual void setOptimizedAcknowledge( bool optimizedAcknowledge );
+
+ virtual const bool getNoRangeAcks() const;
+ virtual bool getNoRangeAcks();
+ virtual void setNoRangeAcks( bool noRangeAcks );
+
+ };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_CONSUMERINFO_H_*/
+
Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ConsumerInfo.h
------------------------------------------------------------------------------
svn:eol-style = native