jessequ
/
qamqp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add autotest for message properties 

enhance test coverage around message properties, allowing for better
refactoring of the properties in general.
This commit is contained in:
Matt Broadstone 2014-08-05 14:30:40 -04:00
parent d5cc6258c6
commit 88e0d0827a
1 changed files with 42 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
tests/auto/qamqpqueue/tst_qamqpqueue.cpp
View File

@ -45,6 +45,7 @@ private Q_SLOTS:
void qos(); void qos();
void invalidRoutingKey(); void invalidRoutingKey();
void tableFieldDataTypes(); void tableFieldDataTypes();
void messageProperties();
private: private:
void declareQueueAndVerifyConsuming(Queue *queue); void declareQueueAndVerifyConsuming(Queue *queue);
@ -612,6 +613,47 @@ void tst_QAMQPQueue::tableFieldDataTypes()
QCOMPARE(receivedDecimal.value, quint32(12345)); 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) QTEST_MAIN(tst_QAMQPQueue)
#include "tst_qamqpqueue.moc" #include "tst_qamqpqueue.moc"