activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r427057 [8/22] - in /incubator/activemq/trunk/amazon: ./ amq_brokersession/ amq_corelib/ amq_examples/ amq_examples/bs_async_recv/ amq_examples/bs_send/ amq_examples/bs_sync_recv/ amq_examples/cl_send/ amq_transport/ command/ marshal/
Date Mon, 31 Jul 2006 09:36:51 GMT
Added: incubator/activemq/trunk/amazon/command/BrokerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/BrokerInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/BrokerInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/BrokerInfo.cpp Mon Jul 31 02:36:40 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.
+*/
+
+#include "command/BrokerInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for BrokerInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+BrokerInfo::isMarshalAware() const
+{
+    return false;
+}
+
+BrokerInfo::BrokerInfo()
+{
+    brokerURL_ = "";
+    brokerName_ = "";
+    slaveBroker_ = 0;
+    masterBroker_ = 0;
+    faultTolerantConfiguration_ = 0;
+}
+
+int
+BrokerInfo::getCommandType() const
+{
+    return TYPE;
+}
+
+BrokerInfo::~BrokerInfo()
+{
+}
+
+boost::shared_ptr<const BrokerId> BrokerInfo::getBrokerId() const
+{
+    return brokerId_;
+}
+
+void BrokerInfo::setBrokerId(const boost::shared_ptr<BrokerId>& brokerId)
+{
+    brokerId_ = brokerId;
+}
+
+const std::string& BrokerInfo::getBrokerURL() const
+{
+    return brokerURL_;
+}
+
+void BrokerInfo::setBrokerURL(const std::string& brokerURL)
+{
+    brokerURL_ = brokerURL;
+}
+
+const std::vector<boost::shared_ptr<const BrokerInfo> >& BrokerInfo::getPeerBrokerInfos() const
+{
+    return peerBrokerInfos_;
+}
+
+void BrokerInfo::setPeerBrokerInfos(const std::vector<boost::shared_ptr<const BrokerInfo> >& peerBrokerInfos)
+{
+    peerBrokerInfos_ = peerBrokerInfos;
+}
+
+const std::string& BrokerInfo::getBrokerName() const
+{
+    return brokerName_;
+}
+
+void BrokerInfo::setBrokerName(const std::string& brokerName)
+{
+    brokerName_ = brokerName;
+}
+
+bool BrokerInfo::isSlaveBroker() const
+{
+    return slaveBroker_;
+}
+
+void BrokerInfo::setSlaveBroker(bool slaveBroker)
+{
+    slaveBroker_ = slaveBroker;
+}
+
+bool BrokerInfo::isMasterBroker() const
+{
+    return masterBroker_;
+}
+
+void BrokerInfo::setMasterBroker(bool masterBroker)
+{
+    masterBroker_ = masterBroker;
+}
+
+bool BrokerInfo::isFaultTolerantConfiguration() const
+{
+    return faultTolerantConfiguration_;
+}
+
+void BrokerInfo::setFaultTolerantConfiguration(bool faultTolerantConfiguration)
+{
+    faultTolerantConfiguration_ = faultTolerantConfiguration;
+}

Propchange: incubator/activemq/trunk/amazon/command/BrokerInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/BrokerInfo.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/BrokerInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/BrokerInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/BrokerInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/BrokerInfo.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,91 @@
+/*
+  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 BrokerInfo_h_
+#define BrokerInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "BrokerId.h"
+#include "BrokerInfo.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for BrokerInfo
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class BrokerInfo : public BaseCommand
+    {
+      private:
+        boost::shared_ptr<const BrokerId> brokerId_;
+        std::string brokerURL_;
+        std::vector<boost::shared_ptr<const BrokerInfo> > peerBrokerInfos_;
+        std::string brokerName_;
+        bool slaveBroker_;
+        bool masterBroker_;
+        bool faultTolerantConfiguration_;
+
+      public:
+        const static int TYPE = 2;
+    
+      public:
+        BrokerInfo();
+        virtual ~BrokerInfo();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual boost::shared_ptr<const BrokerId> getBrokerId() const;
+        virtual void setBrokerId(const boost::shared_ptr<BrokerId>& brokerId);
+
+        virtual const std::string& getBrokerURL() const;
+        virtual void setBrokerURL(const std::string& brokerURL);
+
+        virtual const std::vector<boost::shared_ptr<const BrokerInfo> >& getPeerBrokerInfos() const;
+        virtual void setPeerBrokerInfos(const std::vector<boost::shared_ptr<const BrokerInfo> >& peerBrokerInfos);
+
+        virtual const std::string& getBrokerName() const;
+        virtual void setBrokerName(const std::string& brokerName);
+
+        virtual bool isSlaveBroker() const;
+        virtual void setSlaveBroker(bool slaveBroker);
+
+        virtual bool isMasterBroker() const;
+        virtual void setMasterBroker(bool masterBroker);
+
+        virtual bool isFaultTolerantConfiguration() const;
+        virtual void setFaultTolerantConfiguration(bool faultTolerantConfiguration);
+    };
+  }
+}
+
+#endif /*BrokerInfo_h_*/

Propchange: incubator/activemq/trunk/amazon/command/BrokerInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/BrokerInfo.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/CommandTypes.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/CommandTypes.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/CommandTypes.h (added)
+++ incubator/activemq/trunk/amazon/command/CommandTypes.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,167 @@
+/*
+  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 CommandTypes_hpp
+#define CommandTypes_hpp
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /**
+     * Holds the command id constants used by the command objects.
+     * 
+     * @version $Revision$
+     */
+    class Types {
+      public:
+        // A marshaling layer can use this type to specify a null object.
+        const static int NULLTYPE                          = 0;
+
+        ///////////////////////////////////////////////////
+        //
+        // Info objects sent back and forth client/server when
+        // setting up a client connection.
+        //
+        ///////////////////////////////////////////////////    
+        const static int WIREFORMAT_INFO                   = 1;
+        const static int BROKER_INFO                       = 2;
+        const static int CONNECTION_INFO                   = 3;
+        const static int SESSION_INFO                      = 4;
+        const static int CONSUMER_INFO                     = 5;
+        const static int PRODUCER_INFO                     = 6;
+        const static int TRANSACTION_INFO                  = 7;
+        const static int DESTINATION_INFO                  = 8;
+        const static int REMOVE_SUBSCRIPTION_INFO          = 9;
+        const static int KEEP_ALIVE_INFO                   = 10;
+        const static int SHUTDOWN_INFO                     = 11;
+        const static int REMOVE_INFO                       = 12;
+        const static int CONTROL_COMMAND                   = 14;
+        const static int FLUSH_COMMAND                     = 15;
+        const static int CONNECTION_ERROR                  = 16;
+    
+        ///////////////////////////////////////////////////
+        //
+        // Messages that go back and forth between the client
+        // and the server.
+        //
+        ///////////////////////////////////////////////////    
+        const static int MESSAGE_DISPATCH                  = 21;
+        const static int MESSAGE_ACK                       = 22;
+    
+        const static int ACTIVEMQ_MESSAGE                  = 23;
+        const static int ACTIVEMQ_BYTES_MESSAGE            = 24;
+        const static int ACTIVEMQ_MAP_MESSAGE              = 25;
+        const static int ACTIVEMQ_OBJECT_MESSAGE           = 26;
+        const static int ACTIVEMQ_STREAM_MESSAGE           = 27;
+        const static int ACTIVEMQ_TEXT_MESSAGE             = 28;
+
+        ///////////////////////////////////////////////////
+        //
+        // Command Response messages
+        //
+        ///////////////////////////////////////////////////    
+        const static int RESPONSE                          = 30;
+        const static int EXCEPTION_RESPONSE                = 31;
+        const static int DATA_RESPONSE                     = 32;
+        const static int DATA_ARRAY_RESPONSE               = 33;
+        const static int INTEGER_RESPONSE                  = 34;
+
+
+        ///////////////////////////////////////////////////
+        //
+        // Used by discovery
+        //
+        ///////////////////////////////////////////////////    
+        const static int DISCOVERY_EVENT                   = 40;
+    
+        ///////////////////////////////////////////////////
+        //
+        // Command object used by the Journal
+        //
+        ///////////////////////////////////////////////////    
+        const static int JOURNAL_ACK                       = 50;
+        const static int JOURNAL_REMOVE                    = 52;
+        const static int JOURNAL_TRACE                     = 53;
+        const static int JOURNAL_TRANSACTION               = 54;
+        const static int DURABLE_SUBSCRIPTION_INFO         = 55;
+
+
+        ///////////////////////////////////////////////////
+        //
+        // Reliability and fragmentation
+        //
+        ///////////////////////////////////////////////////    
+        const static int PARTIAL_COMMAND                   = 60;
+        const static int PARTIAL_LAST_COMMAND              = 61;
+    
+        const static int REPLAY                            = 65;
+
+
+
+    
+        ///////////////////////////////////////////////////
+        //
+        // Types used represent basic Java types.
+        //
+        ///////////////////////////////////////////////////    
+        const static int BYTE_TYPE                         = 70;
+        const static int CHAR_TYPE                         = 71;
+        const static int SHORT_TYPE                        = 72;
+        const static int INTEGER_TYPE                      = 73;
+        const static int LONG_TYPE                         = 74;
+        const static int DOUBLE_TYPE                       = 75;
+        const static int FLOAT_TYPE                        = 76;
+        const static int STRING_TYPE                       = 77;
+        const static int BOOLEAN_TYPE                      = 78;
+        const static int BYTE_ARRAY_TYPE                   = 79;
+    
+        ///////////////////////////////////////////////////
+        //
+        // Broker to Broker command objects
+        //
+        /////////////////////////////////////////////////// 
+    
+        const static int MESSAGE_DISPATCH_NOTIFICATION     = 90;
+        const static int NETWORK_BRIDGE_FILTER             = 91;
+    
+        ///////////////////////////////////////////////////
+        //
+        // Data structures contained in the command objects.
+        //
+        ///////////////////////////////////////////////////    
+        const static int ACTIVEMQ_QUEUE                    = 100;
+        const static int ACTIVEMQ_TOPIC                    = 101;
+        const static int ACTIVEMQ_TEMP_QUEUE               = 102;
+        const static int ACTIVEMQ_TEMP_TOPIC               = 103;
+    
+        const static int MESSAGE_ID                        = 110;
+        const static int ACTIVEMQ_LOCAL_TRANSACTION_ID     = 111;
+        const static int ACTIVEMQ_XA_TRANSACTION_ID        = 112;
+
+        const static int CONNECTION_ID                     = 120;
+        const static int SESSION_ID                        = 121;
+        const static int CONSUMER_ID                       = 122;
+        const static int PRODUCER_ID                       = 123;
+        const static int BROKER_ID                         = 124;
+    };
+  };
+};
+
+#endif /*CommandTypes_hpp*/

Propchange: incubator/activemq/trunk/amazon/command/CommandTypes.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/CommandTypes.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionControl.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionControl.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionControl.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,107 @@
+/*
+  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 "command/ConnectionControl.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionControl
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConnectionControl::isMarshalAware() const
+{
+    return false;
+}
+
+ConnectionControl::ConnectionControl()
+{
+    close_ = 0;
+    exit_ = 0;
+    faultTolerant_ = 0;
+    resume_ = 0;
+    suspend_ = 0;
+}
+
+int
+ConnectionControl::getCommandType() const
+{
+    return TYPE;
+}
+
+ConnectionControl::~ConnectionControl()
+{
+}
+
+bool ConnectionControl::isClose() const
+{
+    return close_;
+}
+
+void ConnectionControl::setClose(bool close)
+{
+    close_ = close;
+}
+
+bool ConnectionControl::isExit() const
+{
+    return exit_;
+}
+
+void ConnectionControl::setExit(bool exit)
+{
+    exit_ = exit;
+}
+
+bool ConnectionControl::isFaultTolerant() const
+{
+    return faultTolerant_;
+}
+
+void ConnectionControl::setFaultTolerant(bool faultTolerant)
+{
+    faultTolerant_ = faultTolerant;
+}
+
+bool ConnectionControl::isResume() const
+{
+    return resume_;
+}
+
+void ConnectionControl::setResume(bool resume)
+{
+    resume_ = resume;
+}
+
+bool ConnectionControl::isSuspend() const
+{
+    return suspend_;
+}
+
+void ConnectionControl::setSuspend(bool suspend)
+{
+    suspend_ = suspend;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConnectionControl.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionControl.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionControl.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionControl.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionControl.h (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionControl.h Mon Jul 31 02:36:40 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 ConnectionControl_h_
+#define ConnectionControl_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConnectionControl
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConnectionControl : public BaseCommand
+    {
+      private:
+        bool close_;
+        bool exit_;
+        bool faultTolerant_;
+        bool resume_;
+        bool suspend_;
+
+      public:
+        const static int TYPE = 18;
+    
+      public:
+        ConnectionControl();
+        virtual ~ConnectionControl();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual bool isClose() const;
+        virtual void setClose(bool close);
+
+        virtual bool isExit() const;
+        virtual void setExit(bool exit);
+
+        virtual bool isFaultTolerant() const;
+        virtual void setFaultTolerant(bool faultTolerant);
+
+        virtual bool isResume() const;
+        virtual void setResume(bool resume);
+
+        virtual bool isSuspend() const;
+        virtual void setSuspend(bool suspend);
+    };
+  }
+}
+
+#endif /*ConnectionControl_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConnectionControl.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionControl.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionError.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionError.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionError.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionError.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,72 @@
+/*
+  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 "command/ConnectionError.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionError
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConnectionError::isMarshalAware() const
+{
+    return false;
+}
+
+ConnectionError::ConnectionError()
+{
+}
+
+int
+ConnectionError::getCommandType() const
+{
+    return TYPE;
+}
+
+ConnectionError::~ConnectionError()
+{
+}
+
+const boost::shared_ptr<const BrokerError>& ConnectionError::getException() const
+{
+    return exception_;
+}
+
+void ConnectionError::setException(const boost::shared_ptr<BrokerError>& exception)
+{
+    exception_ = exception;
+}
+
+boost::shared_ptr<const ConnectionId> ConnectionError::getConnectionId() const
+{
+    return connectionId_;
+}
+
+void ConnectionError::setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId)
+{
+    connectionId_ = connectionId;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConnectionError.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionError.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionError.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionError.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionError.h (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionError.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,71 @@
+/*
+  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 ConnectionError_h_
+#define ConnectionError_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "BrokerError.h"
+#include "ConnectionId.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConnectionError
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConnectionError : public BaseCommand
+    {
+      private:
+        boost::shared_ptr<const BrokerError> exception_;
+        boost::shared_ptr<const ConnectionId> connectionId_;
+
+      public:
+        const static int TYPE = 16;
+    
+      public:
+        ConnectionError();
+        virtual ~ConnectionError();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const boost::shared_ptr<const BrokerError>& getException() const;
+        virtual void setException(const boost::shared_ptr<BrokerError>& exception);
+
+        virtual boost::shared_ptr<const ConnectionId> getConnectionId() const;
+        virtual void setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId);
+    };
+  }
+}
+
+#endif /*ConnectionError_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConnectionError.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionError.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionId.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionId.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionId.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,63 @@
+/*
+  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 "command/ConnectionId.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConnectionId::isMarshalAware() const
+{
+    return false;
+}
+
+ConnectionId::ConnectionId()
+{
+    value_ = "";
+}
+
+int
+ConnectionId::getCommandType() const
+{
+    return TYPE;
+}
+
+ConnectionId::~ConnectionId()
+{
+}
+
+const std::string& ConnectionId::getValue() const
+{
+    return value_;
+}
+
+void ConnectionId::setValue(const std::string& value)
+{
+    value_ = value;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConnectionId.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionId.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionId.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionId.h (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionId.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,65 @@
+/*
+  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 ConnectionId_h_
+#define ConnectionId_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/AbstractCommand.h"    
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConnectionId
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConnectionId : public AbstractCommand
+    {
+      private:
+        std::string value_;
+
+      public:
+        const static int TYPE = 120;
+    
+      public:
+        ConnectionId();
+        virtual ~ConnectionId();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const std::string& getValue() const;
+        virtual void setValue(const std::string& value);
+    };
+  }
+}
+
+#endif /*ConnectionId_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConnectionId.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionId.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp Mon Jul 31 02:36:40 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.
+*/
+
+#include "command/ConnectionInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConnectionInfo::isMarshalAware() const
+{
+    return false;
+}
+
+ConnectionInfo::ConnectionInfo()
+{
+    clientId_ = "";
+    password_ = "";
+    userName_ = "";
+    brokerMasterConnector_ = 0;
+    manageable_ = 0;
+}
+
+int
+ConnectionInfo::getCommandType() const
+{
+    return TYPE;
+}
+
+ConnectionInfo::~ConnectionInfo()
+{
+}
+
+boost::shared_ptr<const ConnectionId> ConnectionInfo::getConnectionId() const
+{
+    return connectionId_;
+}
+
+void ConnectionInfo::setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId)
+{
+    connectionId_ = connectionId;
+}
+
+const std::string& ConnectionInfo::getClientId() const
+{
+    return clientId_;
+}
+
+void ConnectionInfo::setClientId(const std::string& clientId)
+{
+    clientId_ = clientId;
+}
+
+const std::string& ConnectionInfo::getPassword() const
+{
+    return password_;
+}
+
+void ConnectionInfo::setPassword(const std::string& password)
+{
+    password_ = password;
+}
+
+const std::string& ConnectionInfo::getUserName() const
+{
+    return userName_;
+}
+
+void ConnectionInfo::setUserName(const std::string& userName)
+{
+    userName_ = userName;
+}
+
+const std::vector<boost::shared_ptr<const BrokerId> >& ConnectionInfo::getBrokerPath() const
+{
+    return brokerPath_;
+}
+
+void ConnectionInfo::setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath)
+{
+    brokerPath_ = brokerPath;
+}
+
+bool ConnectionInfo::isBrokerMasterConnector() const
+{
+    return brokerMasterConnector_;
+}
+
+void ConnectionInfo::setBrokerMasterConnector(bool brokerMasterConnector)
+{
+    brokerMasterConnector_ = brokerMasterConnector;
+}
+
+bool ConnectionInfo::isManageable() const
+{
+    return manageable_;
+}
+
+void ConnectionInfo::setManageable(bool manageable)
+{
+    manageable_ = manageable;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionInfo.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConnectionInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConnectionInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConnectionInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/ConnectionInfo.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,91 @@
+/*
+  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 ConnectionInfo_h_
+#define ConnectionInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "ConnectionId.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConnectionInfo
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConnectionInfo : public BaseCommand
+    {
+      private:
+        boost::shared_ptr<const ConnectionId> connectionId_;
+        std::string clientId_;
+        std::string password_;
+        std::string userName_;
+        std::vector<boost::shared_ptr<const BrokerId> > brokerPath_;
+        bool brokerMasterConnector_;
+        bool manageable_;
+
+      public:
+        const static int TYPE = 3;
+    
+      public:
+        ConnectionInfo();
+        virtual ~ConnectionInfo();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual boost::shared_ptr<const ConnectionId> getConnectionId() const;
+        virtual void setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId);
+
+        virtual const std::string& getClientId() const;
+        virtual void setClientId(const std::string& clientId);
+
+        virtual const std::string& getPassword() const;
+        virtual void setPassword(const std::string& password);
+
+        virtual const std::string& getUserName() const;
+        virtual void setUserName(const std::string& userName);
+
+        virtual const std::vector<boost::shared_ptr<const BrokerId> >& getBrokerPath() const;
+        virtual void setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath);
+
+        virtual bool isBrokerMasterConnector() const;
+        virtual void setBrokerMasterConnector(bool brokerMasterConnector);
+
+        virtual bool isManageable() const;
+        virtual void setManageable(bool manageable);
+    };
+  }
+}
+
+#endif /*ConnectionInfo_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConnectionInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConnectionInfo.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerControl.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerControl.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerControl.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerControl.cpp Mon Jul 31 02:36:40 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 "command/ConsumerControl.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConsumerControl
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConsumerControl::isMarshalAware() const
+{
+    return false;
+}
+
+ConsumerControl::ConsumerControl()
+{
+    close_ = 0;
+    prefetch_ = 0;
+}
+
+int
+ConsumerControl::getCommandType() const
+{
+    return TYPE;
+}
+
+ConsumerControl::~ConsumerControl()
+{
+}
+
+bool ConsumerControl::isClose() const
+{
+    return close_;
+}
+
+void ConsumerControl::setClose(bool close)
+{
+    close_ = close;
+}
+
+boost::shared_ptr<const ConsumerId> ConsumerControl::getConsumerId() const
+{
+    return consumerId_;
+}
+
+void ConsumerControl::setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId)
+{
+    consumerId_ = consumerId;
+}
+
+int ConsumerControl::getPrefetch() const
+{
+    return prefetch_;
+}
+
+void ConsumerControl::setPrefetch(int prefetch)
+{
+    prefetch_ = prefetch;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConsumerControl.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerControl.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerControl.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerControl.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerControl.h (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerControl.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,74 @@
+/*
+  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 ConsumerControl_h_
+#define ConsumerControl_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "ConsumerId.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConsumerControl
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConsumerControl : public BaseCommand
+    {
+      private:
+        bool close_;
+        boost::shared_ptr<const ConsumerId> consumerId_;
+        int prefetch_;
+
+      public:
+        const static int TYPE = 17;
+    
+      public:
+        ConsumerControl();
+        virtual ~ConsumerControl();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual bool isClose() const;
+        virtual void setClose(bool close);
+
+        virtual boost::shared_ptr<const ConsumerId> getConsumerId() const;
+        virtual void setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId);
+
+        virtual int getPrefetch() const;
+        virtual void setPrefetch(int prefetch);
+    };
+  }
+}
+
+#endif /*ConsumerControl_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConsumerControl.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerControl.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerId.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerId.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerId.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,85 @@
+/*
+  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 "command/ConsumerId.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConsumerId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConsumerId::isMarshalAware() const
+{
+    return false;
+}
+
+ConsumerId::ConsumerId()
+{
+    connectionId_ = "";
+    sessionId_ = 0;
+    value_ = 0;
+}
+
+int
+ConsumerId::getCommandType() const
+{
+    return TYPE;
+}
+
+ConsumerId::~ConsumerId()
+{
+}
+
+const std::string& ConsumerId::getConnectionId() const
+{
+    return connectionId_;
+}
+
+void ConsumerId::setConnectionId(const std::string& connectionId)
+{
+    connectionId_ = connectionId;
+}
+
+int64_t ConsumerId::getSessionId() const
+{
+    return sessionId_;
+}
+
+void ConsumerId::setSessionId(int64_t sessionId)
+{
+    sessionId_ = sessionId;
+}
+
+int64_t ConsumerId::getValue() const
+{
+    return value_;
+}
+
+void ConsumerId::setValue(int64_t value)
+{
+    value_ = value;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConsumerId.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerId.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerId.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerId.h (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerId.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,73 @@
+/*
+  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 ConsumerId_h_
+#define ConsumerId_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/AbstractCommand.h"    
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConsumerId
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConsumerId : public AbstractCommand
+    {
+      private:
+        std::string connectionId_;
+        int64_t sessionId_;
+        int64_t value_;
+
+      public:
+        const static int TYPE = 122;
+    
+      public:
+        ConsumerId();
+        virtual ~ConsumerId();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const std::string& getConnectionId() const;
+        virtual void setConnectionId(const std::string& connectionId);
+
+        virtual int64_t getSessionId() const;
+        virtual void setSessionId(int64_t sessionId);
+
+        virtual int64_t getValue() const;
+        virtual void setValue(int64_t value);
+    };
+  }
+}
+
+#endif /*ConsumerId_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConsumerId.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerId.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,225 @@
+/*
+  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 "command/ConsumerInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConsumerInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ConsumerInfo::isMarshalAware() const
+{
+    return false;
+}
+
+ConsumerInfo::ConsumerInfo()
+{
+    browser_ = 0;
+    prefetchSize_ = 0;
+    maximumPendingMessageLimit_ = 0;
+    dispatchAsync_ = 0;
+    selector_ = "";
+    subcriptionName_ = "";
+    noLocal_ = 0;
+    exclusive_ = 0;
+    retroactive_ = 0;
+    priority_ = 0;
+    networkSubscription_ = 0;
+    optimizedAcknowledge_ = 0;
+    noRangeAcks_ = 0;
+}
+
+int
+ConsumerInfo::getCommandType() const
+{
+    return TYPE;
+}
+
+ConsumerInfo::~ConsumerInfo()
+{
+}
+
+boost::shared_ptr<const ConsumerId> ConsumerInfo::getConsumerId() const
+{
+    return consumerId_;
+}
+
+void ConsumerInfo::setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId)
+{
+    consumerId_ = consumerId;
+}
+
+bool ConsumerInfo::isBrowser() const
+{
+    return browser_;
+}
+
+void ConsumerInfo::setBrowser(bool browser)
+{
+    browser_ = browser;
+}
+
+boost::shared_ptr<const ActiveMQDestination> ConsumerInfo::getDestination() const
+{
+    return destination_;
+}
+
+void ConsumerInfo::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+    destination_ = destination;
+}
+
+int ConsumerInfo::getPrefetchSize() const
+{
+    return prefetchSize_;
+}
+
+void ConsumerInfo::setPrefetchSize(int prefetchSize)
+{
+    prefetchSize_ = prefetchSize;
+}
+
+int ConsumerInfo::getMaximumPendingMessageLimit() const
+{
+    return maximumPendingMessageLimit_;
+}
+
+void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
+{
+    maximumPendingMessageLimit_ = maximumPendingMessageLimit;
+}
+
+bool ConsumerInfo::isDispatchAsync() const
+{
+    return dispatchAsync_;
+}
+
+void ConsumerInfo::setDispatchAsync(bool dispatchAsync)
+{
+    dispatchAsync_ = dispatchAsync;
+}
+
+const std::string& ConsumerInfo::getSelector() const
+{
+    return selector_;
+}
+
+void ConsumerInfo::setSelector(const std::string& selector)
+{
+    selector_ = selector;
+}
+
+const std::string& ConsumerInfo::getSubcriptionName() const
+{
+    return subcriptionName_;
+}
+
+void ConsumerInfo::setSubcriptionName(const std::string& subcriptionName)
+{
+    subcriptionName_ = subcriptionName;
+}
+
+bool ConsumerInfo::isNoLocal() const
+{
+    return noLocal_;
+}
+
+void ConsumerInfo::setNoLocal(bool noLocal)
+{
+    noLocal_ = noLocal;
+}
+
+bool ConsumerInfo::isExclusive() const
+{
+    return exclusive_;
+}
+
+void ConsumerInfo::setExclusive(bool exclusive)
+{
+    exclusive_ = exclusive;
+}
+
+bool ConsumerInfo::isRetroactive() const
+{
+    return retroactive_;
+}
+
+void ConsumerInfo::setRetroactive(bool retroactive)
+{
+    retroactive_ = retroactive;
+}
+
+uint8_t ConsumerInfo::getPriority() const
+{
+    return priority_;
+}
+
+void ConsumerInfo::setPriority(uint8_t priority)
+{
+    priority_ = priority;
+}
+
+const std::vector<boost::shared_ptr<const BrokerId> >& ConsumerInfo::getBrokerPath() const
+{
+    return brokerPath_;
+}
+
+void ConsumerInfo::setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath)
+{
+    brokerPath_ = brokerPath;
+}
+
+bool ConsumerInfo::isNetworkSubscription() const
+{
+    return networkSubscription_;
+}
+
+void ConsumerInfo::setNetworkSubscription(bool networkSubscription)
+{
+    networkSubscription_ = networkSubscription;
+}
+
+bool ConsumerInfo::isOptimizedAcknowledge() const
+{
+    return optimizedAcknowledge_;
+}
+
+void ConsumerInfo::setOptimizedAcknowledge(bool optimizedAcknowledge)
+{
+    optimizedAcknowledge_ = optimizedAcknowledge;
+}
+
+bool ConsumerInfo::isNoRangeAcks() const
+{
+    return noRangeAcks_;
+}
+
+void ConsumerInfo::setNoRangeAcks(bool noRangeAcks)
+{
+    noRangeAcks_ = noRangeAcks;
+}

Propchange: incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerInfo.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ConsumerInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ConsumerInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ConsumerInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/ConsumerInfo.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,128 @@
+/*
+  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 ConsumerInfo_h_
+#define ConsumerInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "ConsumerId.h"
+#include "ActiveMQDestination.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ConsumerInfo
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ConsumerInfo : public BaseCommand
+    {
+      private:
+        boost::shared_ptr<const ConsumerId> consumerId_;
+        bool browser_;
+        boost::shared_ptr<const ActiveMQDestination> destination_;
+        int prefetchSize_;
+        int maximumPendingMessageLimit_;
+        bool dispatchAsync_;
+        std::string selector_;
+        std::string subcriptionName_;
+        bool noLocal_;
+        bool exclusive_;
+        bool retroactive_;
+        uint8_t priority_;
+        std::vector<boost::shared_ptr<const BrokerId> > brokerPath_;
+        bool networkSubscription_;
+        bool optimizedAcknowledge_;
+        bool noRangeAcks_;
+
+      public:
+        const static int TYPE = 5;
+    
+      public:
+        ConsumerInfo();
+        virtual ~ConsumerInfo();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual boost::shared_ptr<const ConsumerId> getConsumerId() const;
+        virtual void setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId);
+
+        virtual bool isBrowser() const;
+        virtual void setBrowser(bool browser);
+
+        virtual boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+        virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+        virtual int getPrefetchSize() const;
+        virtual void setPrefetchSize(int prefetchSize);
+
+        virtual int getMaximumPendingMessageLimit() const;
+        virtual void setMaximumPendingMessageLimit(int maximumPendingMessageLimit);
+
+        virtual bool isDispatchAsync() const;
+        virtual void setDispatchAsync(bool dispatchAsync);
+
+        virtual const std::string& getSelector() const;
+        virtual void setSelector(const std::string& selector);
+
+        virtual const std::string& getSubcriptionName() const;
+        virtual void setSubcriptionName(const std::string& subcriptionName);
+
+        virtual bool isNoLocal() const;
+        virtual void setNoLocal(bool noLocal);
+
+        virtual bool isExclusive() const;
+        virtual void setExclusive(bool exclusive);
+
+        virtual bool isRetroactive() const;
+        virtual void setRetroactive(bool retroactive);
+
+        virtual uint8_t getPriority() const;
+        virtual void setPriority(uint8_t priority);
+
+        virtual const std::vector<boost::shared_ptr<const BrokerId> >& getBrokerPath() const;
+        virtual void setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath);
+
+        virtual bool isNetworkSubscription() const;
+        virtual void setNetworkSubscription(bool networkSubscription);
+
+        virtual bool isOptimizedAcknowledge() const;
+        virtual void setOptimizedAcknowledge(bool optimizedAcknowledge);
+
+        virtual bool isNoRangeAcks() const;
+        virtual void setNoRangeAcks(bool noRangeAcks);
+    };
+  }
+}
+
+#endif /*ConsumerInfo_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ConsumerInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ConsumerInfo.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ControlCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ControlCommand.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ControlCommand.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ControlCommand.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,63 @@
+/*
+  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 "command/ControlCommand.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ControlCommand
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+ControlCommand::isMarshalAware() const
+{
+    return false;
+}
+
+ControlCommand::ControlCommand()
+{
+    command_ = "";
+}
+
+int
+ControlCommand::getCommandType() const
+{
+    return TYPE;
+}
+
+ControlCommand::~ControlCommand()
+{
+}
+
+const std::string& ControlCommand::getCommand() const
+{
+    return command_;
+}
+
+void ControlCommand::setCommand(const std::string& command)
+{
+    command_ = command;
+}

Propchange: incubator/activemq/trunk/amazon/command/ControlCommand.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ControlCommand.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/ControlCommand.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ControlCommand.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ControlCommand.h (added)
+++ incubator/activemq/trunk/amazon/command/ControlCommand.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,65 @@
+/*
+  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 ControlCommand_h_
+#define ControlCommand_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for ControlCommand
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class ControlCommand : public BaseCommand
+    {
+      private:
+        std::string command_;
+
+      public:
+        const static int TYPE = 14;
+    
+      public:
+        ControlCommand();
+        virtual ~ControlCommand();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const std::string& getCommand() const;
+        virtual void setCommand(const std::string& command);
+    };
+  }
+}
+
+#endif /*ControlCommand_h_*/

Propchange: incubator/activemq/trunk/amazon/command/ControlCommand.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/ControlCommand.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp (added)
+++ incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,62 @@
+/*
+  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 "command/DataArrayResponse.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DataArrayResponse
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+DataArrayResponse::isMarshalAware() const
+{
+    return false;
+}
+
+DataArrayResponse::DataArrayResponse()
+{
+}
+
+int
+DataArrayResponse::getCommandType() const
+{
+    return TYPE;
+}
+
+DataArrayResponse::~DataArrayResponse()
+{
+}
+
+const std::vector<boost::shared_ptr<const IDataStructure> >& DataArrayResponse::getData() const
+{
+    return data_;
+}
+
+void DataArrayResponse::setData(const std::vector<boost::shared_ptr<const IDataStructure> >& data)
+{
+    data_ = data;
+}

Propchange: incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DataArrayResponse.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DataArrayResponse.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DataArrayResponse.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DataArrayResponse.h (added)
+++ incubator/activemq/trunk/amazon/command/DataArrayResponse.h Mon Jul 31 02:36:40 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.
+*/
+
+#ifndef DataArrayResponse_h_
+#define DataArrayResponse_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/Response.h"    
+#include "IDataStructure.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for DataArrayResponse
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class DataArrayResponse : public Response
+    {
+      private:
+        std::vector<boost::shared_ptr<const IDataStructure> > data_;
+
+      public:
+        const static int TYPE = 33;
+    
+      public:
+        DataArrayResponse();
+        virtual ~DataArrayResponse();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const std::vector<boost::shared_ptr<const IDataStructure> >& getData() const;
+        virtual void setData(const std::vector<boost::shared_ptr<const IDataStructure> >& data);
+    };
+  }
+}
+
+#endif /*DataArrayResponse_h_*/

Propchange: incubator/activemq/trunk/amazon/command/DataArrayResponse.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DataArrayResponse.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DataResponse.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DataResponse.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DataResponse.cpp (added)
+++ incubator/activemq/trunk/amazon/command/DataResponse.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,62 @@
+/*
+  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 "command/DataResponse.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DataResponse
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+DataResponse::isMarshalAware() const
+{
+    return false;
+}
+
+DataResponse::DataResponse()
+{
+}
+
+int
+DataResponse::getCommandType() const
+{
+    return TYPE;
+}
+
+DataResponse::~DataResponse()
+{
+}
+
+const boost::shared_ptr<const IDataStructure>& DataResponse::getData() const
+{
+    return data_;
+}
+
+void DataResponse::setData(const boost::shared_ptr<IDataStructure>& data)
+{
+    data_ = data;
+}

Propchange: incubator/activemq/trunk/amazon/command/DataResponse.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DataResponse.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DataResponse.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DataResponse.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DataResponse.h (added)
+++ incubator/activemq/trunk/amazon/command/DataResponse.h Mon Jul 31 02:36:40 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.
+*/
+
+#ifndef DataResponse_h_
+#define DataResponse_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/Response.h"    
+#include "IDataStructure.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for DataResponse
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class DataResponse : public Response
+    {
+      private:
+        boost::shared_ptr<const IDataStructure> data_;
+
+      public:
+        const static int TYPE = 32;
+    
+      public:
+        DataResponse();
+        virtual ~DataResponse();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const boost::shared_ptr<const IDataStructure>& getData() const;
+        virtual void setData(const boost::shared_ptr<IDataStructure>& data);
+    };
+  }
+}
+
+#endif /*DataResponse_h_*/

Propchange: incubator/activemq/trunk/amazon/command/DataResponse.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DataResponse.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DestinationInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DestinationInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DestinationInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/DestinationInfo.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,104 @@
+/*
+  Licensed to the Apache Software Foundation (ASF) under one
+  or more contributor license agreements.  See the NOTICE file
+  distributed with this work for additional information
+  regarding copyright ownership.  The ASF licenses this file
+  to you under the Apache License, Version 2.0 (the
+  "License"); you may not use this file except in compliance
+  with the License.  You may obtain a copy of the License at
+  
+  http://www.apache.org/licenses/LICENSE-2.0
+  
+  Unless required by applicable law or agreed to in writing,
+  software distributed under the License is distributed on an
+  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+  KIND, either express or implied.  See the License for the
+  specific language governing permissions and limitations
+  under the License.
+*/
+
+#include "command/DestinationInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DestinationInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+DestinationInfo::isMarshalAware() const
+{
+    return false;
+}
+
+DestinationInfo::DestinationInfo()
+{
+    operationType_ = 0;
+    timeout_ = 0;
+}
+
+int
+DestinationInfo::getCommandType() const
+{
+    return TYPE;
+}
+
+DestinationInfo::~DestinationInfo()
+{
+}
+
+boost::shared_ptr<const ConnectionId> DestinationInfo::getConnectionId() const
+{
+    return connectionId_;
+}
+
+void DestinationInfo::setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId)
+{
+    connectionId_ = connectionId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> DestinationInfo::getDestination() const
+{
+    return destination_;
+}
+
+void DestinationInfo::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+    destination_ = destination;
+}
+
+uint8_t DestinationInfo::getOperationType() const
+{
+    return operationType_;
+}
+
+void DestinationInfo::setOperationType(uint8_t operationType)
+{
+    operationType_ = operationType;
+}
+
+int64_t DestinationInfo::getTimeout() const
+{
+    return timeout_;
+}
+
+void DestinationInfo::setTimeout(int64_t timeout)
+{
+    timeout_ = timeout;
+}
+
+const std::vector<boost::shared_ptr<const BrokerId> >& DestinationInfo::getBrokerPath() const
+{
+    return brokerPath_;
+}
+
+void DestinationInfo::setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath)
+{
+    brokerPath_ = brokerPath;
+}

Propchange: incubator/activemq/trunk/amazon/command/DestinationInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DestinationInfo.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DestinationInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DestinationInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DestinationInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/DestinationInfo.h Mon Jul 31 02:36:40 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.
+*/
+
+#ifndef DestinationInfo_h_
+#define DestinationInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"    
+#include "ConnectionId.h"
+#include "ActiveMQDestination.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for DestinationInfo
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class DestinationInfo : public BaseCommand
+    {
+      private:
+        boost::shared_ptr<const ConnectionId> connectionId_;
+        boost::shared_ptr<const ActiveMQDestination> destination_;
+        uint8_t operationType_;
+        int64_t timeout_;
+        std::vector<boost::shared_ptr<const BrokerId> > brokerPath_;
+
+      public:
+        const static int TYPE = 8;
+    
+      public:
+        DestinationInfo();
+        virtual ~DestinationInfo();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual boost::shared_ptr<const ConnectionId> getConnectionId() const;
+        virtual void setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId);
+
+        virtual boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+        virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+        virtual uint8_t getOperationType() const;
+        virtual void setOperationType(uint8_t operationType);
+
+        virtual int64_t getTimeout() const;
+        virtual void setTimeout(int64_t timeout);
+
+        virtual const std::vector<boost::shared_ptr<const BrokerId> >& getBrokerPath() const;
+        virtual void setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath);
+    };
+  }
+}
+
+#endif /*DestinationInfo_h_*/

Propchange: incubator/activemq/trunk/amazon/command/DestinationInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DestinationInfo.h
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp (added)
+++ incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,74 @@
+/*
+  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 "command/DiscoveryEvent.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DiscoveryEvent
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+bool
+DiscoveryEvent::isMarshalAware() const
+{
+    return false;
+}
+
+DiscoveryEvent::DiscoveryEvent()
+{
+    serviceName_ = "";
+    brokerName_ = "";
+}
+
+int
+DiscoveryEvent::getCommandType() const
+{
+    return TYPE;
+}
+
+DiscoveryEvent::~DiscoveryEvent()
+{
+}
+
+const std::string& DiscoveryEvent::getServiceName() const
+{
+    return serviceName_;
+}
+
+void DiscoveryEvent::setServiceName(const std::string& serviceName)
+{
+    serviceName_ = serviceName;
+}
+
+const std::string& DiscoveryEvent::getBrokerName() const
+{
+    return brokerName_;
+}
+
+void DiscoveryEvent::setBrokerName(const std::string& brokerName)
+{
+    brokerName_ = brokerName;
+}

Propchange: incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/amazon/command/DiscoveryEvent.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/amazon/command/DiscoveryEvent.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/DiscoveryEvent.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/DiscoveryEvent.h (added)
+++ incubator/activemq/trunk/amazon/command/DiscoveryEvent.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,69 @@
+/*
+  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 DiscoveryEvent_h_
+#define DiscoveryEvent_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/AbstractCommand.h"    
+
+namespace ActiveMQ {
+  namespace Command {
+
+    /*
+     *
+     *  Marshalling code for Open Wire Format for DiscoveryEvent
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Groovy scripts in the
+     *         activemq-core module
+     *
+     */
+    class DiscoveryEvent : public AbstractCommand
+    {
+      private:
+        std::string serviceName_;
+        std::string brokerName_;
+
+      public:
+        const static int TYPE = 40;
+    
+      public:
+        DiscoveryEvent();
+        virtual ~DiscoveryEvent();
+    
+        virtual bool isMarshalAware() const;
+        virtual int getCommandType() const;
+
+        virtual const std::string& getServiceName() const;
+        virtual void setServiceName(const std::string& serviceName);
+
+        virtual const std::string& getBrokerName() const;
+        virtual void setBrokerName(const std::string& brokerName);
+    };
+  }
+}
+
+#endif /*DiscoveryEvent_h_*/



Mime
View raw message