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

check standard message headers 

improve code coverage by checking a few standard message headers
during queue autotests
This commit is contained in:
Matt Broadstone 2014-07-29 13:26:18 -04:00
parent fe7f9f09ef
commit a75307ae9f
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -45,6 +45,9 @@ private Q_SLOTS:
private: private:
void declareQueueAndVerifyConsuming(Queue *queue); void declareQueueAndVerifyConsuming(Queue *queue);
void verifyStandardMessageHeaders(const Message &message, const QString &routingKey,
const QString &exchangeName = QLatin1String(""),
bool redelivered = false);
QScopedPointer<Client> client; QScopedPointer<Client> client;
}; };
@ -62,6 +65,14 @@ void tst_QAMQPQueue::declareQueueAndVerifyConsuming(Queue *queue)
QCOMPARE(arguments.at(0).toString(), queue->consumerTag()); QCOMPARE(arguments.at(0).toString(), queue->consumerTag());
} }
void tst_QAMQPQueue::verifyStandardMessageHeaders(const Message &message, const QString &routingKey,
const QString &exchangeName, bool redelivered)
{
QCOMPARE(message.routingKey(), routingKey);
QCOMPARE(message.exchangeName(), exchangeName);
QCOMPARE(message.isRedelivered(), redelivered);
}
void tst_QAMQPQueue::init() void tst_QAMQPQueue::init()
{ {
client.reset(new Client); client.reset(new Client);
@ -86,6 +97,7 @@ void tst_QAMQPQueue::defaultExchange()
defaultExchange->publish("first message", "test-default-exchange"); defaultExchange->publish("first message", "test-default-exchange");
QVERIFY(waitForSignal(queue, SIGNAL(messageReceived()))); QVERIFY(waitForSignal(queue, SIGNAL(messageReceived())));
Message message = queue->dequeue(); Message message = queue->dequeue();
verifyStandardMessageHeaders(message, "test-default-exchange");
QCOMPARE(message.payload(), QByteArray("first message")); QCOMPARE(message.payload(), QByteArray("first message"));
} }
@ -115,7 +127,9 @@ void tst_QAMQPQueue::standardExchanges()
Exchange *defaultExchange = client->createExchange(exchange); Exchange *defaultExchange = client->createExchange(exchange);
defaultExchange->publish("test message", routingKey); defaultExchange->publish("test message", routingKey);
QVERIFY(waitForSignal(queue, SIGNAL(messageReceived()))); QVERIFY(waitForSignal(queue, SIGNAL(messageReceived())));
QCOMPARE(queue->dequeue().payload(), QByteArray("test message")); Message message = queue->dequeue();
verifyStandardMessageHeaders(message, routingKey, exchange);
QCOMPARE(message.payload(), QByteArray("test message"));
} }
void tst_QAMQPQueue::invalidDeclaration_data() void tst_QAMQPQueue::invalidDeclaration_data()
@ -410,6 +424,7 @@ void tst_QAMQPQueue::get()
} }
Message message = queue->dequeue(); Message message = queue->dequeue();
verifyStandardMessageHeaders(message, "test-get");
QCOMPARE(message.payload(), expected.toUtf8()); QCOMPARE(message.payload(), expected.toUtf8());
queue->ack(message); queue->ack(message);
} }
@ -434,6 +449,7 @@ void tst_QAMQPQueue::verifyContentEncodingIssue33()
QVERIFY(waitForSignal(queue, SIGNAL(messageReceived()))); QVERIFY(waitForSignal(queue, SIGNAL(messageReceived())));
Message message = queue->dequeue(); Message message = queue->dequeue();
verifyStandardMessageHeaders(message, "test-issue-33");
QVERIFY(message.hasProperty(Message::ContentEncoding)); QVERIFY(message.hasProperty(Message::ContentEncoding));
QString contentType = message.property(Message::ContentEncoding).toString(); QString contentType = message.property(Message::ContentEncoding).toString();
QCOMPARE(contentType, QLatin1String("fakeContentEncoding")); QCOMPARE(contentType, QLatin1String("fakeContentEncoding"));
@ -490,6 +506,7 @@ void tst_QAMQPQueue::qos()
while (!queue->isEmpty()) { while (!queue->isEmpty()) {
QString expected = QString("message %1").arg(messageReceivedCount); QString expected = QString("message %1").arg(messageReceivedCount);
Message message = queue->dequeue(); Message message = queue->dequeue();
verifyStandardMessageHeaders(message, "test-qos");
QCOMPARE(message.payload(), expected.toUtf8()); QCOMPARE(message.payload(), expected.toUtf8());
queue->ack(message); queue->ack(message);
messageReceivedCount++; messageReceivedCount++;