summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/Cluster_child.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/tests/Cluster_child.cpp')
-rw-r--r--qpid/cpp/src/tests/Cluster_child.cpp3
1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/cpp/src/tests/Cluster_child.cpp b/qpid/cpp/src/tests/Cluster_child.cpp
index c03d7396f0..8d0682473b 100644
--- a/qpid/cpp/src/tests/Cluster_child.cpp
+++ b/qpid/cpp/src/tests/Cluster_child.cpp
@@ -35,8 +35,7 @@ static const ProtocolVersion VER;
/** Child part of Cluster::clusterTwo test */
void clusterTwo() {
TestCluster cluster("clusterTwo", "amqp:child:2");
- AMQFrame frame;
- BOOST_REQUIRE(cluster.received.waitPop(frame)); // Frame from parent.
+ AMQFrame frame = cluster.received.pop(frame); // Frame from parent.
BOOST_CHECK_TYPEID_EQUAL(SessionOpenBody, *frame.getBody());
BOOST_CHECK_EQUAL(2u, cluster.size()); // Me and parent