[*] remove dependency from QObjectPrivate

src/qamqp/amqp_global.h

@@ -0,0 +1,32 @@
+#ifndef qamqp_global_h__
+#define qamqp_global_h__
+
+#include <QtCore/qglobal.h>
+
+#define QAMQP_P_INCLUDE
+#define AMQPSCHEME "amqp"
+#define AMQPPORT 5672
+#define AMQPHOST "localhost"
+#define AMQPVHOST "/"
+#define AMQPLOGIN "guest"
+#define AMQPPSWD  "guest"
+#define FRAME_MAX 131072
+
+#define AMQP_CONNECTION_FORCED 320
+
+#define P_DECLARE_PRIVATE(Class) \
+	friend class Class##Private; \
+	inline Class##Private* pd_func() { return reinterpret_cast<Class##Private *>(this->pd_ptr); } \
+	inline const Class##Private* pd_func() const { return reinterpret_cast<const Class##Private *>(this->pd_ptr); } 	
+	
+
+#define P_DECLARE_PUBLIC(Class) \
+	inline Class* pq_func() { return static_cast<Class *>(this->pq_ptr); } \
+	inline const Class* pq_func() const { return static_cast<const Class *>(this->pq_ptr); } \
+	friend class Class; 
+
+
+#define P_D(Class) Class##Private * const d = this->pd_func()
+#define P_Q(Class) Class * const q = this->pq_func()
+
+#endif // qamqp_global_h__

src/test.cpp

@@ -19,9 +19,9 @@ Test::Test()
 	exchange_->bind(queue_);
 	exchange_->bind(queue2_);
 
-	connect(queue_, SIGNAL(declared()), this, SLOT(declared()));
-	connect(queue_, SIGNAL(messageRecieved()), this, SLOT(newMessage()));
-	
+	connect(queue2_, SIGNAL(declared()), this, SLOT(declared()));
+
+	connect(queue_, SIGNAL(messageRecieved()), this, SLOT(newMessage()));	
 	connect(queue2_, SIGNAL(messageRecieved()), this, SLOT(newMessage()));
 }
 
@@ -34,17 +34,20 @@ void Test::declared()
 {
 	qDebug("\t-= Ready =-");
 	//queue_->purge();
-	QFile f("D:/geoip.eap");
-	f.open(QIODevice::ReadOnly);
-	exchange_->publish(f.readAll(), exchange_->name(), "image/jpg");
+
+	exchange_->publish("123", exchange_->name());
 	//queue_->remove(true, false, false);
 	queue_->setQOS(0,10);
 	queue_->setConsumerTag("qamqp-consumer");
 	queue_->consume(QAMQP::Queue::coNoAck);
+	//queue_->setNoAck(false);
+	//queue_->get();
+
 
 	queue2_->setQOS(0,10);
 	queue2_->setConsumerTag("qamqp-consumer2");
 	queue2_->consume(QAMQP::Queue::coNoAck);
+
 	//exchange_->remove(false, false);
 }
 
@@ -58,6 +61,10 @@ void Test::newMessage()
 		qDebug("| Exchange-name: %s", qPrintable(message->exchangeName));
 		qDebug("| Routing-key: %s", qPrintable(message->routeKey));
 		qDebug("| Content-type: %s", qPrintable(message->property[QAMQP::Frame::Content::cpContentType].toString()));
+		if(!q->noAck())
+		{
+			q->ack(message);
+		}
 
 	}
 

src/test.h

@@ -12,6 +12,7 @@ public:
 	Test();
 	~Test();
 
+	Q_INVOKABLE void test() {};
 private slots:
 
 	void declared();