diff options
| -rw-r--r-- | cpp/src/tests/QueueEvents.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/tests/QueueEvents.cpp b/cpp/src/tests/QueueEvents.cpp index f6b76b69ba..3e377d04b3 100644 --- a/cpp/src/tests/QueueEvents.cpp +++ b/cpp/src/tests/QueueEvents.cpp @@ -79,14 +79,15 @@ QPID_AUTO_TEST_CASE(testBasicEventProcessing) QueuedMessage event1(&queue, MessageUtils::createMessage(), id); QueuedMessage event2(&queue, MessageUtils::createMessage(), ++id); - events.enqueued(event1); - events.enqueued(event2); - events.dequeued(event1); //define events expected by listener: listener.expect(QueueEvents::Event(QueueEvents::ENQUEUE, event1)); listener.expect(QueueEvents::Event(QueueEvents::ENQUEUE, event2)); listener.expect(QueueEvents::Event(QueueEvents::DEQUEUE, event1)); + events.enqueued(event1); + events.enqueued(event2); + events.dequeued(event1); + dispatchThread.join(); events.shutdown(); events.unregisterListener("dummy"); |