From 88e0d0827ac053803f56374b45558e03e030d999 Mon Sep 17 00:00:00 2001
From: Matt Broadstone <mbroadstone@devonit.com>
Date: Tue, 5 Aug 2014 14:30:40 -0400
Subject: [PATCH] add autotest for message properties

enhance test coverage around message properties, allowing for better
refactoring of the properties in general.
---
 tests/auto/qamqpqueue/tst_qamqpqueue.cpp | 42 ++++++++++++++++++++++++
 1 file changed, 42 insertions(+)

diff --git a/tests/auto/qamqpqueue/tst_qamqpqueue.cpp b/tests/auto/qamqpqueue/tst_qamqpqueue.cpp
index 5542240..7645ca1 100644
--- a/tests/auto/qamqpqueue/tst_qamqpqueue.cpp
+++ b/tests/auto/qamqpqueue/tst_qamqpqueue.cpp
@@ -45,6 +45,7 @@ private Q_SLOTS:
     void qos();
     void invalidRoutingKey();
     void tableFieldDataTypes();
+    void messageProperties();
 
 private:
     void declareQueueAndVerifyConsuming(Queue *queue);
@@ -612,6 +613,47 @@ void tst_QAMQPQueue::tableFieldDataTypes()
     QCOMPARE(receivedDecimal.value, quint32(12345));
 }
 
+void tst_QAMQPQueue::messageProperties()
+{
+    Queue *queue = client->createQueue("test-message-properties");
+    declareQueueAndVerifyConsuming(queue);
+
+    QDateTime timestamp = QDateTime::currentDateTime();
+    MessageProperties properties;
+    properties.insert(Frame::Content::cpContentType, "some-content-type");
+    properties.insert(Frame::Content::cpContentEncoding, "some-content-encoding");
+    properties.insert(Frame::Content::cpDeliveryMode, 2);
+    properties.insert(Frame::Content::cpPriority, 5);
+    properties.insert(Frame::Content::cpCorrelationId, 42);
+    properties.insert(Frame::Content::cpReplyTo, "another-queue");
+    properties.insert(Frame::Content::cpMessageId, "some-message-id");
+    properties.insert(Frame::Content::cpExpiration, "60000");
+    properties.insert(Frame::Content::cpTimestamp, timestamp);
+    properties.insert(Frame::Content::cpType, "some-message-type");
+    properties.insert(Frame::Content::cpUserId, "guest");
+    properties.insert(Frame::Content::cpAppId, "some-app-id");
+    properties.insert(Frame::Content::cpClusterID, "some-cluster-id");
+
+    Exchange *defaultExchange = client->createExchange();
+    defaultExchange->publish("dummy", "test-message-properties", properties);
+    QVERIFY(waitForSignal(queue, SIGNAL(messageReceived())));
+    Message message = queue->dequeue();
+
+    QCOMPARE(message.property(Message::ContentType).toString(), QLatin1String("some-content-type"));
+    QCOMPARE(message.property(Message::ContentEncoding).toString(), QLatin1String("some-content-encoding"));
+    QCOMPARE(message.property(Message::DeliveryMode).toInt(), 2);
+    QCOMPARE(message.property(Message::Priority).toInt(), 5);
+    QCOMPARE(message.property(Message::CorrelationId).toInt(), 42);
+    QCOMPARE(message.property(Message::ReplyTo).toString(), QLatin1String("another-queue"));
+    QCOMPARE(message.property(Message::MessageId).toString(), QLatin1String("some-message-id"));
+    QCOMPARE(message.property(Message::Expiration).toString(), QLatin1String("60000"));
+    QCOMPARE(message.property(Message::Timestamp).toDateTime(), timestamp);
+    QCOMPARE(message.property(Message::Type).toString(), QLatin1String("some-message-type"));
+    QCOMPARE(message.property(Message::UserId).toString(), QLatin1String("guest"));
+    QCOMPARE(message.property(Message::AppId).toString(), QLatin1String("some-app-id"));
+    QCOMPARE(message.property(Message::ClusterID).toString(), QLatin1String("some-cluster-id"));
+}
+
 
 QTEST_MAIN(tst_QAMQPQueue)
 #include "tst_qamqpqueue.moc"