1 files changed, 86 insertions, 0 deletions
diff --git a/cpp/client/inc/Message.h b/cpp/client/inc/Message.h
new file mode 100644
index 0000000000..f8a5aef565
--- /dev/null
+++ b/cpp/client/inc/Message.h
@@ -0,0 +1,86 @@
+/*
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed 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 <string>
+#include "amqp_framing.h"
+
+#ifndef _Message_
+#define _Message_
+
+
+namespace qpid {
+namespace client {
+
+    class Message{
+	qpid::framing::AMQHeaderBody::shared_ptr header;
+	string data;
+	bool redelivered;
+        u_int64_t deliveryTag;
+
+        qpid::framing::BasicHeaderProperties* getHeaderProperties();
+	Message(qpid::framing::AMQHeaderBody::shared_ptr& header);
+    public:
+	Message();
+	~Message();
+	
+	inline std::string getData(){ return data; }
+	inline void setData(const std::string& data){ this->data = data; }
+
+	inline bool isRedelivered(){ return redelivered; }
+	inline void setRedelivered(bool redelivered){ this->redelivered = redelivered; }
+
+        inline u_int64_t getDeliveryTag(){ return deliveryTag; }
+
+        std::string& getContentType();
+        std::string& getContentEncoding();
+        qpid::framing::FieldTable& getHeaders();
+        u_int8_t getDeliveryMode();
+        u_int8_t getPriority();
+        std::string& getCorrelationId();
+        std::string& getReplyTo();
+        std::string& getExpiration();
+        std::string& getMessageId();
+        u_int64_t getTimestamp();
+        std::string& getType();
+        std::string& getUserId();
+        std::string& getAppId();
+        std::string& getClusterId();
+
+	void setContentType(std::string& type);
+	void setContentEncoding(std::string& encoding);
+	void setHeaders(qpid::framing::FieldTable& headers);
+	void setDeliveryMode(u_int8_t mode);
+	void setPriority(u_int8_t priority);
+	void setCorrelationId(std::string& correlationId);
+	void setReplyTo(std::string& replyTo);
+	void setExpiration(std::string&  expiration);
+	void setMessageId(std::string& messageId);
+	void setTimestamp(u_int64_t timestamp);
+	void setType(std::string& type);
+	void setUserId(std::string& userId);
+	void setAppId(std::string& appId);
+	void setClusterId(std::string& clusterId);
+
+
+	friend class Channel;
+    };
+
+}
+}
+
+
+#endif