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

added autotests for exclusive queues

This commit is contained in:
Matt Broadstone 2014-06-09 15:10:35 -04:00
parent 613bd5ba96
commit aff5fb70b7
1 changed files with 49 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -19,7 +19,9 @@ private Q_SLOTS:
void standardExchanges_data();
void standardExchanges();
void unnamedQueue();
void unnamed();
void exclusiveAccess();
void exclusiveRemoval();
void remove();
void removeIfUnused();
@ -42,8 +44,10 @@ void tst_QAMQPQueue::init()
void tst_QAMQPQueue::cleanup()
{
client->disconnectFromHost();
QVERIFY(waitForSignal(client.data(), SIGNAL(disconnected())));
if (client->isConnected()) {
client->disconnectFromHost();
QVERIFY(waitForSignal(client.data(), SIGNAL(disconnected())));
}
}
void tst_QAMQPQueue::defaultExchange()
@ -92,7 +96,7 @@ void tst_QAMQPQueue::standardExchanges()
QCOMPARE(queue->getMessage().payload(), QByteArray("test message"));
}
void tst_QAMQPQueue::unnamedQueue()
void tst_QAMQPQueue::unnamed()
{
Queue *queue = client->createQueue();
queue->declare();
@ -102,6 +106,45 @@ void tst_QAMQPQueue::unnamedQueue()
QVERIFY(!queue->name().isEmpty());
}
void tst_QAMQPQueue::exclusiveAccess()
{
Queue *queue = client->createQueue("test-exclusive-queue");
queue->declare(Queue::Exclusive);
QVERIFY(waitForSignal(queue, SIGNAL(declared())));
Client secondClient;
secondClient.connectToHost();
QVERIFY(waitForSignal(&secondClient, SIGNAL(connected())));
Queue *passiveQueue = secondClient.createQueue("test-exclusive-queue");
passiveQueue->declare(Queue::Passive);
QVERIFY(waitForSignal(passiveQueue, SIGNAL(error(ChannelError))));
QCOMPARE(passiveQueue->error(), Channel::ResourceLockedError);
secondClient.disconnectFromHost();
QVERIFY(waitForSignal(&secondClient, SIGNAL(disconnected())));
}
void tst_QAMQPQueue::exclusiveRemoval()
{
Queue *queue = client->createQueue("test-exclusive-queue");
queue->declare(Queue::Exclusive);
QVERIFY(waitForSignal(queue, SIGNAL(declared())));
client.data()->disconnectFromHost();
QVERIFY(waitForSignal(client.data(), SIGNAL(disconnected())));
// create a new client and try to access the queue that should
// no longer exist
Client secondClient;
secondClient.connectToHost();
QVERIFY(waitForSignal(&secondClient, SIGNAL(connected())));
Queue *passiveQueue = secondClient.createQueue("test-exclusive-queue");
passiveQueue->declare(Queue::Passive);
QVERIFY(waitForSignal(passiveQueue, SIGNAL(error(ChannelError))));
QCOMPARE(passiveQueue->error(), Channel::NotFoundError);
secondClient.disconnectFromHost();
QVERIFY(waitForSignal(&secondClient, SIGNAL(disconnected())));
}
void tst_QAMQPQueue::remove()
{
Queue *queue = client->createQueue("test-remove");
@ -120,7 +163,7 @@ void tst_QAMQPQueue::removeIfUnused()
queue->remove(Queue::roIfUnused);
QVERIFY(waitForSignal(queue, SIGNAL(error(ChannelError))));
QCOMPARE(queue->error(), Channel::PreconditionFailed);
QCOMPARE(queue->error(), Channel::PreconditionFailedError);
QVERIFY(!queue->errorString().isEmpty());
}
@ -140,7 +183,7 @@ void tst_QAMQPQueue::removeIfEmpty()
queue->remove(Queue::roIfEmpty);
QVERIFY(waitForSignal(queue, SIGNAL(error(ChannelError))));
QCOMPARE(queue->error(), Channel::PreconditionFailed);
QCOMPARE(queue->error(), Channel::PreconditionFailedError);
QVERIFY(!queue->errorString().isEmpty());
}