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 [10/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/Message.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/Message.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/Message.cpp (added)
+++ incubator/activemq/trunk/amazon/command/Message.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,315 @@
+/*
+ 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/Message.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for Message
+ *
+ *
+ * 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
+Message::isMarshalAware() const
+{
+ return true;
+}
+
+Message::Message()
+{
+ groupID_ = "";
+ groupSequence_ = 0;
+ correlationId_ = "";
+ persistent_ = 0;
+ expiration_ = 0;
+ priority_ = 0;
+ timestamp_ = 0;
+ type_ = "";
+ compressed_ = 0;
+ redeliveryCounter_ = 0;
+ arrival_ = 0;
+ userID_ = "";
+ recievedByDFBridge_ = 0;
+}
+
+int
+Message::getCommandType() const
+{
+ return TYPE;
+}
+
+Message::~Message()
+{
+}
+
+boost::shared_ptr<const ProducerId> Message::getProducerId() const
+{
+ return producerId_;
+}
+
+void Message::setProducerId(const boost::shared_ptr<ProducerId>& producerId)
+{
+ producerId_ = producerId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> Message::getDestination() const
+{
+ return destination_;
+}
+
+void Message::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+ destination_ = destination;
+}
+
+boost::shared_ptr<const TransactionId> Message::getTransactionId() const
+{
+ return transactionId_;
+}
+
+void Message::setTransactionId(const boost::shared_ptr<TransactionId>& transactionId)
+{
+ transactionId_ = transactionId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> Message::getOriginalDestination() const
+{
+ return originalDestination_;
+}
+
+void Message::setOriginalDestination(const boost::shared_ptr<ActiveMQDestination>& originalDestination)
+{
+ originalDestination_ = originalDestination;
+}
+
+boost::shared_ptr<const MessageId> Message::getMessageId() const
+{
+ return messageId_;
+}
+
+void Message::setMessageId(const boost::shared_ptr<MessageId>& messageId)
+{
+ messageId_ = messageId;
+}
+
+boost::shared_ptr<const TransactionId> Message::getOriginalTransactionId() const
+{
+ return originalTransactionId_;
+}
+
+void Message::setOriginalTransactionId(const boost::shared_ptr<TransactionId>& originalTransactionId)
+{
+ originalTransactionId_ = originalTransactionId;
+}
+
+const std::string& Message::getGroupID() const
+{
+ return groupID_;
+}
+
+void Message::setGroupID(const std::string& groupID)
+{
+ groupID_ = groupID;
+}
+
+int Message::getGroupSequence() const
+{
+ return groupSequence_;
+}
+
+void Message::setGroupSequence(int groupSequence)
+{
+ groupSequence_ = groupSequence;
+}
+
+const std::string& Message::getCorrelationId() const
+{
+ return correlationId_;
+}
+
+void Message::setCorrelationId(const std::string& correlationId)
+{
+ correlationId_ = correlationId;
+}
+
+bool Message::isPersistent() const
+{
+ return persistent_;
+}
+
+void Message::setPersistent(bool persistent)
+{
+ persistent_ = persistent;
+}
+
+int64_t Message::getExpiration() const
+{
+ return expiration_;
+}
+
+void Message::setExpiration(int64_t expiration)
+{
+ expiration_ = expiration;
+}
+
+uint8_t Message::getPriority() const
+{
+ return priority_;
+}
+
+void Message::setPriority(uint8_t priority)
+{
+ priority_ = priority;
+}
+
+boost::shared_ptr<const ActiveMQDestination> Message::getReplyTo() const
+{
+ return replyTo_;
+}
+
+void Message::setReplyTo(const boost::shared_ptr<ActiveMQDestination>& replyTo)
+{
+ replyTo_ = replyTo;
+}
+
+int64_t Message::getTimestamp() const
+{
+ return timestamp_;
+}
+
+void Message::setTimestamp(int64_t timestamp)
+{
+ timestamp_ = timestamp;
+}
+
+const std::string& Message::getType() const
+{
+ return type_;
+}
+
+void Message::setType(const std::string& type)
+{
+ type_ = type;
+}
+
+const std::vector<unsigned char>& Message::getContent() const
+{
+ return content_;
+}
+
+void Message::setContent(const std::vector<uint8_t>& content)
+{
+ content_ = content;
+}
+
+const std::vector<unsigned char>& Message::getMarshalledProperties() const
+{
+ return marshalledProperties_;
+}
+
+void Message::setMarshalledProperties(const std::vector<uint8_t>& marshalledProperties)
+{
+ marshalledProperties_ = marshalledProperties;
+}
+
+const boost::shared_ptr<const IDataStructure>& Message::getDataStructure() const
+{
+ return dataStructure_;
+}
+
+void Message::setDataStructure(const boost::shared_ptr<IDataStructure>& dataStructure)
+{
+ dataStructure_ = dataStructure;
+}
+
+boost::shared_ptr<const ConsumerId> Message::getTargetConsumerId() const
+{
+ return targetConsumerId_;
+}
+
+void Message::setTargetConsumerId(const boost::shared_ptr<ConsumerId>& targetConsumerId)
+{
+ targetConsumerId_ = targetConsumerId;
+}
+
+bool Message::isCompressed() const
+{
+ return compressed_;
+}
+
+void Message::setCompressed(bool compressed)
+{
+ compressed_ = compressed;
+}
+
+int Message::getRedeliveryCounter() const
+{
+ return redeliveryCounter_;
+}
+
+void Message::setRedeliveryCounter(int redeliveryCounter)
+{
+ redeliveryCounter_ = redeliveryCounter;
+}
+
+const std::vector<boost::shared_ptr<const BrokerId> >& Message::getBrokerPath() const
+{
+ return brokerPath_;
+}
+
+void Message::setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath)
+{
+ brokerPath_ = brokerPath;
+}
+
+int64_t Message::getArrival() const
+{
+ return arrival_;
+}
+
+void Message::setArrival(int64_t arrival)
+{
+ arrival_ = arrival;
+}
+
+const std::string& Message::getUserID() const
+{
+ return userID_;
+}
+
+void Message::setUserID(const std::string& userID)
+{
+ userID_ = userID;
+}
+
+bool Message::isRecievedByDFBridge() const
+{
+ return recievedByDFBridge_;
+}
+
+void Message::setRecievedByDFBridge(bool recievedByDFBridge)
+{
+ recievedByDFBridge_ = recievedByDFBridge;
+}
Propchange: incubator/activemq/trunk/amazon/command/Message.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/Message.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/Message.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/Message.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/Message.h (added)
+++ incubator/activemq/trunk/amazon/command/Message.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,171 @@
+/*
+ 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 Message_h_
+#define Message_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"
+#include "ProducerId.h"
+#include "ActiveMQDestination.h"
+#include "TransactionId.h"
+#include "ActiveMQDestination.h"
+#include "MessageId.h"
+#include "TransactionId.h"
+#include "ActiveMQDestination.h"
+#include "IDataStructure.h"
+#include "ConsumerId.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for Message
+ *
+ *
+ * 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 Message : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ProducerId> producerId_;
+ boost::shared_ptr<const ActiveMQDestination> destination_;
+ boost::shared_ptr<const TransactionId> transactionId_;
+ boost::shared_ptr<const ActiveMQDestination> originalDestination_;
+ boost::shared_ptr<const MessageId> messageId_;
+ boost::shared_ptr<const TransactionId> originalTransactionId_;
+ std::string groupID_;
+ int groupSequence_;
+ std::string correlationId_;
+ bool persistent_;
+ int64_t expiration_;
+ uint8_t priority_;
+ boost::shared_ptr<const ActiveMQDestination> replyTo_;
+ int64_t timestamp_;
+ std::string type_;
+ std::vector<uint8_t> content_;
+ std::vector<uint8_t> marshalledProperties_;
+ boost::shared_ptr<const IDataStructure> dataStructure_;
+ boost::shared_ptr<const ConsumerId> targetConsumerId_;
+ bool compressed_;
+ int redeliveryCounter_;
+ std::vector<boost::shared_ptr<const BrokerId> > brokerPath_;
+ int64_t arrival_;
+ std::string userID_;
+ bool recievedByDFBridge_;
+
+ public:
+ const static int TYPE = 0;
+
+ public:
+ Message();
+ virtual ~Message();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual boost::shared_ptr<const ProducerId> getProducerId() const;
+ virtual void setProducerId(const boost::shared_ptr<ProducerId>& producerId);
+
+ virtual boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+ virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+ virtual boost::shared_ptr<const TransactionId> getTransactionId() const;
+ virtual void setTransactionId(const boost::shared_ptr<TransactionId>& transactionId);
+
+ virtual boost::shared_ptr<const ActiveMQDestination> getOriginalDestination() const;
+ virtual void setOriginalDestination(const boost::shared_ptr<ActiveMQDestination>& originalDestination);
+
+ virtual boost::shared_ptr<const MessageId> getMessageId() const;
+ virtual void setMessageId(const boost::shared_ptr<MessageId>& messageId);
+
+ virtual boost::shared_ptr<const TransactionId> getOriginalTransactionId() const;
+ virtual void setOriginalTransactionId(const boost::shared_ptr<TransactionId>& originalTransactionId);
+
+ virtual const std::string& getGroupID() const;
+ virtual void setGroupID(const std::string& groupID);
+
+ virtual int getGroupSequence() const;
+ virtual void setGroupSequence(int groupSequence);
+
+ virtual const std::string& getCorrelationId() const;
+ virtual void setCorrelationId(const std::string& correlationId);
+
+ virtual bool isPersistent() const;
+ virtual void setPersistent(bool persistent);
+
+ virtual int64_t getExpiration() const;
+ virtual void setExpiration(int64_t expiration);
+
+ virtual uint8_t getPriority() const;
+ virtual void setPriority(uint8_t priority);
+
+ virtual boost::shared_ptr<const ActiveMQDestination> getReplyTo() const;
+ virtual void setReplyTo(const boost::shared_ptr<ActiveMQDestination>& replyTo);
+
+ virtual int64_t getTimestamp() const;
+ virtual void setTimestamp(int64_t timestamp);
+
+ virtual const std::string& getType() const;
+ virtual void setType(const std::string& type);
+
+ virtual const std::vector<unsigned char>& getContent() const;
+ virtual void setContent(const std::vector<uint8_t>& content);
+
+ virtual const std::vector<unsigned char>& getMarshalledProperties() const;
+ virtual void setMarshalledProperties(const std::vector<uint8_t>& marshalledProperties);
+
+ virtual const boost::shared_ptr<const IDataStructure>& getDataStructure() const;
+ virtual void setDataStructure(const boost::shared_ptr<IDataStructure>& dataStructure);
+
+ virtual boost::shared_ptr<const ConsumerId> getTargetConsumerId() const;
+ virtual void setTargetConsumerId(const boost::shared_ptr<ConsumerId>& targetConsumerId);
+
+ virtual bool isCompressed() const;
+ virtual void setCompressed(bool compressed);
+
+ virtual int getRedeliveryCounter() const;
+ virtual void setRedeliveryCounter(int redeliveryCounter);
+
+ virtual const std::vector<boost::shared_ptr<const BrokerId> >& getBrokerPath() const;
+ virtual void setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath);
+
+ virtual int64_t getArrival() const;
+ virtual void setArrival(int64_t arrival);
+
+ virtual const std::string& getUserID() const;
+ virtual void setUserID(const std::string& userID);
+
+ virtual bool isRecievedByDFBridge() const;
+ virtual void setRecievedByDFBridge(bool recievedByDFBridge);
+ };
+ }
+}
+
+#endif /*Message_h_*/
Propchange: incubator/activemq/trunk/amazon/command/Message.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/Message.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageAck.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageAck.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageAck.cpp (added)
+++ incubator/activemq/trunk/amazon/command/MessageAck.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,124 @@
+/*
+ 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/MessageAck.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageAck
+ *
+ *
+ * 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
+MessageAck::isMarshalAware() const
+{
+ return false;
+}
+
+MessageAck::MessageAck()
+{
+ ackType_ = 0;
+ messageCount_ = 0;
+}
+
+int
+MessageAck::getCommandType() const
+{
+ return TYPE;
+}
+
+MessageAck::~MessageAck()
+{
+}
+
+boost::shared_ptr<const ActiveMQDestination> MessageAck::getDestination() const
+{
+ return destination_;
+}
+
+void MessageAck::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+ destination_ = destination;
+}
+
+boost::shared_ptr<const TransactionId> MessageAck::getTransactionId() const
+{
+ return transactionId_;
+}
+
+void MessageAck::setTransactionId(const boost::shared_ptr<TransactionId>& transactionId)
+{
+ transactionId_ = transactionId;
+}
+
+boost::shared_ptr<const ConsumerId> MessageAck::getConsumerId() const
+{
+ return consumerId_;
+}
+
+void MessageAck::setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId)
+{
+ consumerId_ = consumerId;
+}
+
+uint8_t MessageAck::getAckType() const
+{
+ return ackType_;
+}
+
+void MessageAck::setAckType(uint8_t ackType)
+{
+ ackType_ = ackType;
+}
+
+boost::shared_ptr<const MessageId> MessageAck::getFirstMessageId() const
+{
+ return firstMessageId_;
+}
+
+void MessageAck::setFirstMessageId(const boost::shared_ptr<MessageId>& firstMessageId)
+{
+ firstMessageId_ = firstMessageId;
+}
+
+boost::shared_ptr<const MessageId> MessageAck::getLastMessageId() const
+{
+ return lastMessageId_;
+}
+
+void MessageAck::setLastMessageId(const boost::shared_ptr<MessageId>& lastMessageId)
+{
+ lastMessageId_ = lastMessageId;
+}
+
+int MessageAck::getMessageCount() const
+{
+ return messageCount_;
+}
+
+void MessageAck::setMessageCount(int messageCount)
+{
+ messageCount_ = messageCount;
+}
Propchange: incubator/activemq/trunk/amazon/command/MessageAck.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageAck.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageAck.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageAck.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageAck.h (added)
+++ incubator/activemq/trunk/amazon/command/MessageAck.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,94 @@
+/*
+ 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 MessageAck_h_
+#define MessageAck_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"
+#include "ActiveMQDestination.h"
+#include "TransactionId.h"
+#include "ConsumerId.h"
+#include "MessageId.h"
+#include "MessageId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for MessageAck
+ *
+ *
+ * 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 MessageAck : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ActiveMQDestination> destination_;
+ boost::shared_ptr<const TransactionId> transactionId_;
+ boost::shared_ptr<const ConsumerId> consumerId_;
+ uint8_t ackType_;
+ boost::shared_ptr<const MessageId> firstMessageId_;
+ boost::shared_ptr<const MessageId> lastMessageId_;
+ int messageCount_;
+
+ public:
+ const static int TYPE = 22;
+
+ public:
+ MessageAck();
+ virtual ~MessageAck();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+ virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+ virtual boost::shared_ptr<const TransactionId> getTransactionId() const;
+ virtual void setTransactionId(const boost::shared_ptr<TransactionId>& transactionId);
+
+ virtual boost::shared_ptr<const ConsumerId> getConsumerId() const;
+ virtual void setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId);
+
+ virtual uint8_t getAckType() const;
+ virtual void setAckType(uint8_t ackType);
+
+ virtual boost::shared_ptr<const MessageId> getFirstMessageId() const;
+ virtual void setFirstMessageId(const boost::shared_ptr<MessageId>& firstMessageId);
+
+ virtual boost::shared_ptr<const MessageId> getLastMessageId() const;
+ virtual void setLastMessageId(const boost::shared_ptr<MessageId>& lastMessageId);
+
+ virtual int getMessageCount() const;
+ virtual void setMessageCount(int messageCount);
+ };
+ }
+}
+
+#endif /*MessageAck_h_*/
Propchange: incubator/activemq/trunk/amazon/command/MessageAck.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageAck.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageDispatch.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageDispatch.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageDispatch.cpp (added)
+++ incubator/activemq/trunk/amazon/command/MessageDispatch.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,93 @@
+/*
+ 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/MessageDispatch.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatch
+ *
+ *
+ * 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
+MessageDispatch::isMarshalAware() const
+{
+ return false;
+}
+
+MessageDispatch::MessageDispatch()
+{
+ redeliveryCounter_ = 0;
+}
+
+int
+MessageDispatch::getCommandType() const
+{
+ return TYPE;
+}
+
+MessageDispatch::~MessageDispatch()
+{
+}
+
+boost::shared_ptr<const ConsumerId> MessageDispatch::getConsumerId() const
+{
+ return consumerId_;
+}
+
+void MessageDispatch::setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId)
+{
+ consumerId_ = consumerId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> MessageDispatch::getDestination() const
+{
+ return destination_;
+}
+
+void MessageDispatch::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+ destination_ = destination;
+}
+
+boost::shared_ptr<const Message> MessageDispatch::getMessage() const
+{
+ return message_;
+}
+
+void MessageDispatch::setMessage(const boost::shared_ptr<Message>& message)
+{
+ message_ = message;
+}
+
+int MessageDispatch::getRedeliveryCounter() const
+{
+ return redeliveryCounter_;
+}
+
+void MessageDispatch::setRedeliveryCounter(int redeliveryCounter)
+{
+ redeliveryCounter_ = redeliveryCounter;
+}
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatch.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatch.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageDispatch.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageDispatch.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageDispatch.h (added)
+++ incubator/activemq/trunk/amazon/command/MessageDispatch.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,80 @@
+/*
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+*/
+
+#ifndef MessageDispatch_h_
+#define MessageDispatch_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 "Message.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatch
+ *
+ *
+ * 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 MessageDispatch : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ConsumerId> consumerId_;
+ boost::shared_ptr<const ActiveMQDestination> destination_;
+ boost::shared_ptr<const Message> message_;
+ int redeliveryCounter_;
+
+ public:
+ const static int TYPE = 21;
+
+ public:
+ MessageDispatch();
+ virtual ~MessageDispatch();
+
+ 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 boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+ virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+ virtual boost::shared_ptr<const Message> getMessage() const;
+ virtual void setMessage(const boost::shared_ptr<Message>& message);
+
+ virtual int getRedeliveryCounter() const;
+ virtual void setRedeliveryCounter(int redeliveryCounter);
+ };
+ }
+}
+
+#endif /*MessageDispatch_h_*/
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatch.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatch.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp (added)
+++ incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,93 @@
+/*
+ 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/MessageDispatchNotification.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatchNotification
+ *
+ *
+ * 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
+MessageDispatchNotification::isMarshalAware() const
+{
+ return false;
+}
+
+MessageDispatchNotification::MessageDispatchNotification()
+{
+ deliverySequenceId_ = 0;
+}
+
+int
+MessageDispatchNotification::getCommandType() const
+{
+ return TYPE;
+}
+
+MessageDispatchNotification::~MessageDispatchNotification()
+{
+}
+
+boost::shared_ptr<const ConsumerId> MessageDispatchNotification::getConsumerId() const
+{
+ return consumerId_;
+}
+
+void MessageDispatchNotification::setConsumerId(const boost::shared_ptr<ConsumerId>& consumerId)
+{
+ consumerId_ = consumerId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> MessageDispatchNotification::getDestination() const
+{
+ return destination_;
+}
+
+void MessageDispatchNotification::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+ destination_ = destination;
+}
+
+int64_t MessageDispatchNotification::getDeliverySequenceId() const
+{
+ return deliverySequenceId_;
+}
+
+void MessageDispatchNotification::setDeliverySequenceId(int64_t deliverySequenceId)
+{
+ deliverySequenceId_ = deliverySequenceId;
+}
+
+boost::shared_ptr<const MessageId> MessageDispatchNotification::getMessageId() const
+{
+ return messageId_;
+}
+
+void MessageDispatchNotification::setMessageId(const boost::shared_ptr<MessageId>& messageId)
+{
+ messageId_ = messageId;
+}
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h (added)
+++ incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,80 @@
+/*
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+*/
+
+#ifndef MessageDispatchNotification_h_
+#define MessageDispatchNotification_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 "MessageId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatchNotification
+ *
+ *
+ * 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 MessageDispatchNotification : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ConsumerId> consumerId_;
+ boost::shared_ptr<const ActiveMQDestination> destination_;
+ int64_t deliverySequenceId_;
+ boost::shared_ptr<const MessageId> messageId_;
+
+ public:
+ const static int TYPE = 90;
+
+ public:
+ MessageDispatchNotification();
+ virtual ~MessageDispatchNotification();
+
+ 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 boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+ virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+ virtual int64_t getDeliverySequenceId() const;
+ virtual void setDeliverySequenceId(int64_t deliverySequenceId);
+
+ virtual boost::shared_ptr<const MessageId> getMessageId() const;
+ virtual void setMessageId(const boost::shared_ptr<MessageId>& messageId);
+ };
+ }
+}
+
+#endif /*MessageDispatchNotification_h_*/
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageDispatchNotification.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageId.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageId.cpp (added)
+++ incubator/activemq/trunk/amazon/command/MessageId.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/MessageId.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageId
+ *
+ *
+ * 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
+MessageId::isMarshalAware() const
+{
+ return false;
+}
+
+MessageId::MessageId()
+{
+ producerSequenceId_ = 0;
+ brokerSequenceId_ = 0;
+}
+
+int
+MessageId::getCommandType() const
+{
+ return TYPE;
+}
+
+MessageId::~MessageId()
+{
+}
+
+boost::shared_ptr<const ProducerId> MessageId::getProducerId() const
+{
+ return producerId_;
+}
+
+void MessageId::setProducerId(const boost::shared_ptr<ProducerId>& producerId)
+{
+ producerId_ = producerId;
+}
+
+int64_t MessageId::getProducerSequenceId() const
+{
+ return producerSequenceId_;
+}
+
+void MessageId::setProducerSequenceId(int64_t producerSequenceId)
+{
+ producerSequenceId_ = producerSequenceId;
+}
+
+int64_t MessageId::getBrokerSequenceId() const
+{
+ return brokerSequenceId_;
+}
+
+void MessageId::setBrokerSequenceId(int64_t brokerSequenceId)
+{
+ brokerSequenceId_ = brokerSequenceId;
+}
Propchange: incubator/activemq/trunk/amazon/command/MessageId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageId.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/MessageId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/MessageId.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/MessageId.h (added)
+++ incubator/activemq/trunk/amazon/command/MessageId.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 MessageId_h_
+#define MessageId_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/AbstractCommand.h"
+#include "ProducerId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for MessageId
+ *
+ *
+ * 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 MessageId : public AbstractCommand
+ {
+ private:
+ boost::shared_ptr<const ProducerId> producerId_;
+ int64_t producerSequenceId_;
+ int64_t brokerSequenceId_;
+
+ public:
+ const static int TYPE = 110;
+
+ public:
+ MessageId();
+ virtual ~MessageId();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual boost::shared_ptr<const ProducerId> getProducerId() const;
+ virtual void setProducerId(const boost::shared_ptr<ProducerId>& producerId);
+
+ virtual int64_t getProducerSequenceId() const;
+ virtual void setProducerSequenceId(int64_t producerSequenceId);
+
+ virtual int64_t getBrokerSequenceId() const;
+ virtual void setBrokerSequenceId(int64_t brokerSequenceId);
+ };
+ }
+}
+
+#endif /*MessageId_h_*/
Propchange: incubator/activemq/trunk/amazon/command/MessageId.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/MessageId.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp (added)
+++ incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp 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.
+*/
+
+#include "command/NetworkBridgeFilter.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for NetworkBridgeFilter
+ *
+ *
+ * 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
+NetworkBridgeFilter::isMarshalAware() const
+{
+ return false;
+}
+
+NetworkBridgeFilter::NetworkBridgeFilter()
+{
+ networkTTL_ = 0;
+}
+
+int
+NetworkBridgeFilter::getCommandType() const
+{
+ return TYPE;
+}
+
+NetworkBridgeFilter::~NetworkBridgeFilter()
+{
+}
+
+int NetworkBridgeFilter::getNetworkTTL() const
+{
+ return networkTTL_;
+}
+
+void NetworkBridgeFilter::setNetworkTTL(int networkTTL)
+{
+ networkTTL_ = networkTTL;
+}
+
+boost::shared_ptr<const BrokerId> NetworkBridgeFilter::getNetworkBrokerId() const
+{
+ return networkBrokerId_;
+}
+
+void NetworkBridgeFilter::setNetworkBrokerId(const boost::shared_ptr<BrokerId>& networkBrokerId)
+{
+ networkBrokerId_ = networkBrokerId;
+}
Propchange: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h (added)
+++ incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,70 @@
+/*
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing,
+ software distributed under the License is distributed on an
+ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ KIND, either express or implied. See the License for the
+ specific language governing permissions and limitations
+ under the License.
+*/
+
+#ifndef NetworkBridgeFilter_h_
+#define NetworkBridgeFilter_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/AbstractCommand.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for NetworkBridgeFilter
+ *
+ *
+ * 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 NetworkBridgeFilter : public AbstractCommand
+ {
+ private:
+ int networkTTL_;
+ boost::shared_ptr<const BrokerId> networkBrokerId_;
+
+ public:
+ const static int TYPE = 91;
+
+ public:
+ NetworkBridgeFilter();
+ virtual ~NetworkBridgeFilter();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual int getNetworkTTL() const;
+ virtual void setNetworkTTL(int networkTTL);
+
+ virtual boost::shared_ptr<const BrokerId> getNetworkBrokerId() const;
+ virtual void setNetworkBrokerId(const boost::shared_ptr<BrokerId>& networkBrokerId);
+ };
+ }
+}
+
+#endif /*NetworkBridgeFilter_h_*/
Propchange: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/NetworkBridgeFilter.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/PartialCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/PartialCommand.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/PartialCommand.cpp (added)
+++ incubator/activemq/trunk/amazon/command/PartialCommand.cpp 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.
+*/
+
+#include "command/PartialCommand.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for PartialCommand
+ *
+ *
+ * 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
+PartialCommand::isMarshalAware() const
+{
+ return false;
+}
+
+PartialCommand::PartialCommand()
+{
+ commandId_ = 0;
+}
+
+int
+PartialCommand::getCommandType() const
+{
+ return TYPE;
+}
+
+PartialCommand::~PartialCommand()
+{
+}
+
+int PartialCommand::getCommandId() const
+{
+ return commandId_;
+}
+
+void PartialCommand::setCommandId(int commandId)
+{
+ commandId_ = commandId;
+}
+
+const std::vector<uint8_t >& PartialCommand::getData() const
+{
+ return data_;
+}
+
+void PartialCommand::setData(const std::vector<uint8_t >& data)
+{
+ data_ = data;
+}
Propchange: incubator/activemq/trunk/amazon/command/PartialCommand.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/PartialCommand.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/PartialCommand.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/PartialCommand.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/PartialCommand.h (added)
+++ incubator/activemq/trunk/amazon/command/PartialCommand.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 PartialCommand_h_
+#define PartialCommand_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 PartialCommand
+ *
+ *
+ * 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 PartialCommand : public AbstractCommand
+ {
+ private:
+ int commandId_;
+ std::vector<uint8_t > data_;
+
+ public:
+ const static int TYPE = 60;
+
+ public:
+ PartialCommand();
+ virtual ~PartialCommand();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual int getCommandId() const;
+ virtual void setCommandId(int commandId);
+
+ virtual const std::vector<uint8_t >& getData() const;
+ virtual void setData(const std::vector<uint8_t >& data);
+ };
+ }
+}
+
+#endif /*PartialCommand_h_*/
Propchange: incubator/activemq/trunk/amazon/command/PartialCommand.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/PartialCommand.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ProducerId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ProducerId.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ProducerId.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ProducerId.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/ProducerId.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ProducerId
+ *
+ *
+ * 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
+ProducerId::isMarshalAware() const
+{
+ return false;
+}
+
+ProducerId::ProducerId()
+{
+ connectionId_ = "";
+ value_ = 0;
+ sessionId_ = 0;
+}
+
+int
+ProducerId::getCommandType() const
+{
+ return TYPE;
+}
+
+ProducerId::~ProducerId()
+{
+}
+
+const std::string& ProducerId::getConnectionId() const
+{
+ return connectionId_;
+}
+
+void ProducerId::setConnectionId(const std::string& connectionId)
+{
+ connectionId_ = connectionId;
+}
+
+int64_t ProducerId::getValue() const
+{
+ return value_;
+}
+
+void ProducerId::setValue(int64_t value)
+{
+ value_ = value;
+}
+
+int64_t ProducerId::getSessionId() const
+{
+ return sessionId_;
+}
+
+void ProducerId::setSessionId(int64_t sessionId)
+{
+ sessionId_ = sessionId;
+}
Propchange: incubator/activemq/trunk/amazon/command/ProducerId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ProducerId.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ProducerId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ProducerId.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ProducerId.h (added)
+++ incubator/activemq/trunk/amazon/command/ProducerId.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 ProducerId_h_
+#define ProducerId_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 ProducerId
+ *
+ *
+ * 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 ProducerId : public AbstractCommand
+ {
+ private:
+ std::string connectionId_;
+ int64_t value_;
+ int64_t sessionId_;
+
+ public:
+ const static int TYPE = 123;
+
+ public:
+ ProducerId();
+ virtual ~ProducerId();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual const std::string& getConnectionId() const;
+ virtual void setConnectionId(const std::string& connectionId);
+
+ virtual int64_t getValue() const;
+ virtual void setValue(int64_t value);
+
+ virtual int64_t getSessionId() const;
+ virtual void setSessionId(int64_t sessionId);
+ };
+ }
+}
+
+#endif /*ProducerId_h_*/
Propchange: incubator/activemq/trunk/amazon/command/ProducerId.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ProducerId.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ProducerInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ProducerInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ProducerInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ProducerInfo.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,82 @@
+/*
+ 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/ProducerInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ProducerInfo
+ *
+ *
+ * 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
+ProducerInfo::isMarshalAware() const
+{
+ return false;
+}
+
+ProducerInfo::ProducerInfo()
+{
+}
+
+int
+ProducerInfo::getCommandType() const
+{
+ return TYPE;
+}
+
+ProducerInfo::~ProducerInfo()
+{
+}
+
+boost::shared_ptr<const ProducerId> ProducerInfo::getProducerId() const
+{
+ return producerId_;
+}
+
+void ProducerInfo::setProducerId(const boost::shared_ptr<ProducerId>& producerId)
+{
+ producerId_ = producerId;
+}
+
+boost::shared_ptr<const ActiveMQDestination> ProducerInfo::getDestination() const
+{
+ return destination_;
+}
+
+void ProducerInfo::setDestination(const boost::shared_ptr<ActiveMQDestination>& destination)
+{
+ destination_ = destination;
+}
+
+const std::vector<boost::shared_ptr<const BrokerId> >& ProducerInfo::getBrokerPath() const
+{
+ return brokerPath_;
+}
+
+void ProducerInfo::setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath)
+{
+ brokerPath_ = brokerPath;
+}
Propchange: incubator/activemq/trunk/amazon/command/ProducerInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ProducerInfo.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ProducerInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ProducerInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ProducerInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/ProducerInfo.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,76 @@
+/*
+ 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 ProducerInfo_h_
+#define ProducerInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"
+#include "ProducerId.h"
+#include "ActiveMQDestination.h"
+#include "BrokerId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for ProducerInfo
+ *
+ *
+ * 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 ProducerInfo : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ProducerId> producerId_;
+ boost::shared_ptr<const ActiveMQDestination> destination_;
+ std::vector<boost::shared_ptr<const BrokerId> > brokerPath_;
+
+ public:
+ const static int TYPE = 6;
+
+ public:
+ ProducerInfo();
+ virtual ~ProducerInfo();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual boost::shared_ptr<const ProducerId> getProducerId() const;
+ virtual void setProducerId(const boost::shared_ptr<ProducerId>& producerId);
+
+ virtual boost::shared_ptr<const ActiveMQDestination> getDestination() const;
+ virtual void setDestination(const boost::shared_ptr<ActiveMQDestination>& destination);
+
+ virtual const std::vector<boost::shared_ptr<const BrokerId> >& getBrokerPath() const;
+ virtual void setBrokerPath(const std::vector<boost::shared_ptr<const BrokerId> >& brokerPath);
+ };
+ }
+}
+
+#endif /*ProducerInfo_h_*/
Propchange: incubator/activemq/trunk/amazon/command/ProducerInfo.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ProducerInfo.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/RemoveInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/RemoveInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/RemoveInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/RemoveInfo.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/RemoveInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for RemoveInfo
+ *
+ *
+ * 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
+RemoveInfo::isMarshalAware() const
+{
+ return false;
+}
+
+RemoveInfo::RemoveInfo()
+{
+}
+
+int
+RemoveInfo::getCommandType() const
+{
+ return TYPE;
+}
+
+RemoveInfo::~RemoveInfo()
+{
+}
+
+const boost::shared_ptr<const IDataStructure>& RemoveInfo::getObjectId() const
+{
+ return objectId_;
+}
+
+void RemoveInfo::setObjectId(const boost::shared_ptr<IDataStructure>& objectId)
+{
+ objectId_ = objectId;
+}
Propchange: incubator/activemq/trunk/amazon/command/RemoveInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/RemoveInfo.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/RemoveInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/RemoveInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/RemoveInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/RemoveInfo.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 RemoveInfo_h_
+#define RemoveInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"
+#include "IDataStructure.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for RemoveInfo
+ *
+ *
+ * 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 RemoveInfo : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const IDataStructure> objectId_;
+
+ public:
+ const static int TYPE = 12;
+
+ public:
+ RemoveInfo();
+ virtual ~RemoveInfo();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual const boost::shared_ptr<const IDataStructure>& getObjectId() const;
+ virtual void setObjectId(const boost::shared_ptr<IDataStructure>& objectId);
+ };
+ }
+}
+
+#endif /*RemoveInfo_h_*/
Propchange: incubator/activemq/trunk/amazon/command/RemoveInfo.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/RemoveInfo.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.cpp (added)
+++ incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.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/RemoveSubscriptionInfo.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+ *
+ *
+ * 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
+RemoveSubscriptionInfo::isMarshalAware() const
+{
+ return false;
+}
+
+RemoveSubscriptionInfo::RemoveSubscriptionInfo()
+{
+ subcriptionName_ = "";
+ clientId_ = "";
+}
+
+int
+RemoveSubscriptionInfo::getCommandType() const
+{
+ return TYPE;
+}
+
+RemoveSubscriptionInfo::~RemoveSubscriptionInfo()
+{
+}
+
+boost::shared_ptr<const ConnectionId> RemoveSubscriptionInfo::getConnectionId() const
+{
+ return connectionId_;
+}
+
+void RemoveSubscriptionInfo::setConnectionId(const boost::shared_ptr<ConnectionId>& connectionId)
+{
+ connectionId_ = connectionId;
+}
+
+const std::string& RemoveSubscriptionInfo::getSubcriptionName() const
+{
+ return subcriptionName_;
+}
+
+void RemoveSubscriptionInfo::setSubcriptionName(const std::string& subcriptionName)
+{
+ subcriptionName_ = subcriptionName;
+}
+
+const std::string& RemoveSubscriptionInfo::getClientId() const
+{
+ return clientId_;
+}
+
+void RemoveSubscriptionInfo::setClientId(const std::string& clientId)
+{
+ clientId_ = clientId;
+}
Propchange: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.h (added)
+++ incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.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 RemoveSubscriptionInfo_h_
+#define RemoveSubscriptionInfo_h_
+
+#include <string>
+#include <vector>
+#include <exception>
+#include <inttypes.h>
+#include <boost/shared_ptr.hpp>
+
+#include "command/BaseCommand.h"
+#include "ConnectionId.h"
+
+namespace ActiveMQ {
+ namespace Command {
+
+ /*
+ *
+ * Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+ *
+ *
+ * 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 RemoveSubscriptionInfo : public BaseCommand
+ {
+ private:
+ boost::shared_ptr<const ConnectionId> connectionId_;
+ std::string subcriptionName_;
+ std::string clientId_;
+
+ public:
+ const static int TYPE = 0;
+
+ public:
+ RemoveSubscriptionInfo();
+ virtual ~RemoveSubscriptionInfo();
+
+ 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& getSubcriptionName() const;
+ virtual void setSubcriptionName(const std::string& subcriptionName);
+
+ virtual const std::string& getClientId() const;
+ virtual void setClientId(const std::string& clientId);
+ };
+ }
+}
+
+#endif /*RemoveSubscriptionInfo_h_*/
Propchange: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/RemoveSubscriptionInfo.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ReplayCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ReplayCommand.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ReplayCommand.cpp (added)
+++ incubator/activemq/trunk/amazon/command/ReplayCommand.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/ReplayCommand.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ReplayCommand
+ *
+ *
+ * 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
+ReplayCommand::isMarshalAware() const
+{
+ return false;
+}
+
+ReplayCommand::ReplayCommand()
+{
+ firstNakNumber_ = 0;
+ lastNakNumber_ = 0;
+}
+
+int
+ReplayCommand::getCommandType() const
+{
+ return TYPE;
+}
+
+ReplayCommand::~ReplayCommand()
+{
+}
+
+int ReplayCommand::getFirstNakNumber() const
+{
+ return firstNakNumber_;
+}
+
+void ReplayCommand::setFirstNakNumber(int firstNakNumber)
+{
+ firstNakNumber_ = firstNakNumber;
+}
+
+int ReplayCommand::getLastNakNumber() const
+{
+ return lastNakNumber_;
+}
+
+void ReplayCommand::setLastNakNumber(int lastNakNumber)
+{
+ lastNakNumber_ = lastNakNumber;
+}
Propchange: incubator/activemq/trunk/amazon/command/ReplayCommand.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ReplayCommand.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/ReplayCommand.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/ReplayCommand.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/ReplayCommand.h (added)
+++ incubator/activemq/trunk/amazon/command/ReplayCommand.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 ReplayCommand_h_
+#define ReplayCommand_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 ReplayCommand
+ *
+ *
+ * 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 ReplayCommand : public BaseCommand
+ {
+ private:
+ int firstNakNumber_;
+ int lastNakNumber_;
+
+ public:
+ const static int TYPE = 65;
+
+ public:
+ ReplayCommand();
+ virtual ~ReplayCommand();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual int getFirstNakNumber() const;
+ virtual void setFirstNakNumber(int firstNakNumber);
+
+ virtual int getLastNakNumber() const;
+ virtual void setLastNakNumber(int lastNakNumber);
+ };
+ }
+}
+
+#endif /*ReplayCommand_h_*/
Propchange: incubator/activemq/trunk/amazon/command/ReplayCommand.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/ReplayCommand.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/Response.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/Response.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/Response.cpp (added)
+++ incubator/activemq/trunk/amazon/command/Response.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/Response.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for Response
+ *
+ *
+ * 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
+Response::isMarshalAware() const
+{
+ return false;
+}
+
+Response::Response()
+{
+ correlationId_ = 0;
+}
+
+int
+Response::getCommandType() const
+{
+ return TYPE;
+}
+
+Response::~Response()
+{
+}
+
+int Response::getCorrelationId() const
+{
+ return correlationId_;
+}
+
+void Response::setCorrelationId(int correlationId)
+{
+ correlationId_ = correlationId;
+}
Propchange: incubator/activemq/trunk/amazon/command/Response.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/Response.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/Response.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/Response.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/Response.h (added)
+++ incubator/activemq/trunk/amazon/command/Response.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 Response_h_
+#define Response_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 Response
+ *
+ *
+ * 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 Response : public BaseCommand
+ {
+ private:
+ int correlationId_;
+
+ public:
+ const static int TYPE = 30;
+
+ public:
+ Response();
+ virtual ~Response();
+
+ virtual bool isMarshalAware() const;
+ virtual int getCommandType() const;
+
+ virtual int getCorrelationId() const;
+ virtual void setCorrelationId(int correlationId);
+ };
+ }
+}
+
+#endif /*Response_h_*/
Propchange: incubator/activemq/trunk/amazon/command/Response.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/Response.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/command/SessionId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/command/SessionId.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/command/SessionId.cpp (added)
+++ incubator/activemq/trunk/amazon/command/SessionId.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/SessionId.h"
+
+using namespace ActiveMQ::Command;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for SessionId
+ *
+ *
+ * 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
+SessionId::isMarshalAware() const
+{
+ return false;
+}
+
+SessionId::SessionId()
+{
+ connectionId_ = "";
+ value_ = 0;
+}
+
+int
+SessionId::getCommandType() const
+{
+ return TYPE;
+}
+
+SessionId::~SessionId()
+{
+}
+
+const std::string& SessionId::getConnectionId() const
+{
+ return connectionId_;
+}
+
+void SessionId::setConnectionId(const std::string& connectionId)
+{
+ connectionId_ = connectionId;
+}
+
+int64_t SessionId::getValue() const
+{
+ return value_;
+}
+
+void SessionId::setValue(int64_t value)
+{
+ value_ = value;
+}
Propchange: incubator/activemq/trunk/amazon/command/SessionId.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/command/SessionId.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL