summaryrefslogtreecommitdiff
path: root/cpp/src/tests/QueueEvents.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/QueueEvents.cpp')
-rw-r--r--cpp/src/tests/QueueEvents.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/tests/QueueEvents.cpp b/cpp/src/tests/QueueEvents.cpp
index 7aea23922d..f6b76b69ba 100644
--- a/cpp/src/tests/QueueEvents.cpp
+++ b/cpp/src/tests/QueueEvents.cpp
@@ -168,7 +168,7 @@ QPID_AUTO_TEST_CASE(testSystemLevelEventProcessing)
BOOST_CHECK_EQUAL(incoming.pop().getData(), (boost::format("%1%_%2%") % "Message" % (i+1)).str());
}
fixture.connection.close();
- fixture.shutdownBroker();
+ fixture.broker->getQueueEvents().shutdown();
//check listener was notified of all events, and in correct order
SequenceNumber enqueueId(1);
@@ -215,7 +215,7 @@ QPID_AUTO_TEST_CASE(testSystemLevelEventProcessing_enqueuesOnly)
BOOST_CHECK_EQUAL(incoming.pop().getData(), (boost::format("%1%_%2%") % "Message" % (i+1)).str());
}
fixture.connection.close();
- fixture.shutdownBroker();
+ fixture.broker->getQueueEvents().shutdown();
//check listener was notified of all events, and in correct order
SequenceNumber enqueueId(1);