activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject 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/...
Date Mon, 02 Oct 2006 14:30:22 GMT
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



Mime
View raw message