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

semi-complete tests around queue requirements

This commit is contained in:
Matt Broadstone 2014-06-11 16:14:33 -04:00
parent 352669f392
commit 14f9b7e955
1 changed files with 48 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,11 +18,13 @@ private Q_SLOTS:
void defaultExchange(); void defaultExchange();
void standardExchanges_data(); void standardExchanges_data();
void standardExchanges(); void standardExchanges();
void invalidDeclaration_data();
void invalidDeclaration();
void invalidBind();
void unnamed(); void unnamed();
void exclusiveAccess(); void exclusiveAccess();
void exclusiveRemoval(); void exclusiveRemoval();
void notFound();
void remove(); void remove();
void removeIfUnused(); void removeIfUnused();
void removeIfEmpty(); void removeIfEmpty();
@ -95,6 +97,42 @@ void tst_QAMQPQueue::standardExchanges()
QCOMPARE(queue->dequeue().payload(), QByteArray("test message")); QCOMPARE(queue->dequeue().payload(), QByteArray("test message"));
} }
void tst_QAMQPQueue::invalidDeclaration_data()
{
QTest::addColumn<QString>("queueName");
QTest::addColumn<QAMQP::Error>("error");
QTest::newRow("amq.direct") << "amq.direct" << QAMQP::AccessRefusedError;
QTest::newRow("amq.fanout") << "amq.fanout" << QAMQP::AccessRefusedError;
QTest::newRow("amq.headers") << "amq.headers" << QAMQP::AccessRefusedError;
QTest::newRow("amq.match") << "amq.match" << QAMQP::AccessRefusedError;
QTest::newRow("amq.topic") << "amq.topic" << QAMQP::AccessRefusedError;
QTest::newRow("amq.reserved") << "amq.reserved" << QAMQP::AccessRefusedError;
}
void tst_QAMQPQueue::invalidDeclaration()
{
QFETCH(QString, queueName);
QFETCH(QAMQP::Error, error);
Queue *queue = client->createQueue(queueName);
queue->declare();
QVERIFY(waitForSignal(queue, SIGNAL(error(QAMQP::Error))));
QCOMPARE(queue->error(), error);
}
void tst_QAMQPQueue::invalidBind()
{
Queue *queue = client->createQueue("test-invalid-bind");
queue->declare();
QVERIFY(waitForSignal(queue, SIGNAL(declared())));
queue->consume(); // for autodelete
queue->bind("non-existant-exchange", "routingKey");
QVERIFY(waitForSignal(queue, SIGNAL(error(QAMQP::Error))));
QCOMPARE(queue->error(), QAMQP::NotFoundError);
}
void tst_QAMQPQueue::unnamed() void tst_QAMQPQueue::unnamed()
{ {
Queue *queue = client->createQueue(); Queue *queue = client->createQueue();
@ -144,6 +182,14 @@ void tst_QAMQPQueue::exclusiveRemoval()
QVERIFY(waitForSignal(&secondClient, SIGNAL(disconnected()))); QVERIFY(waitForSignal(&secondClient, SIGNAL(disconnected())));
} }
void tst_QAMQPQueue::notFound()
{
Queue *queue = client->createQueue("test-not-found");
queue->declare(Queue::Passive);
QVERIFY(waitForSignal(queue, SIGNAL(error(QAMQP::Error))));
QCOMPARE(queue->error(), QAMQP::NotFoundError);
}
void tst_QAMQPQueue::remove() void tst_QAMQPQueue::remove()
{ {
Queue *queue = client->createQueue("test-remove"); Queue *queue = client->createQueue("test-remove");