You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/07/31 11:36:51 UTC
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/
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_*/