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.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/cpp/src/tests/Cluster_child.cpp b/qpid/cpp/src/tests/Cluster_child.cpp
index 9c119e5238..c509dc1950 100644
--- a/qpid/cpp/src/tests/Cluster_child.cpp
+++ b/qpid/cpp/src/tests/Cluster_child.cpp
@@ -32,15 +32,14 @@ static const ProtocolVersion VER;
/** Chlid part of Cluster::clusterTwo test */
void clusterTwo() {
- TestCluster cluster("clusterTwo", "amqp::2");
+ TestCluster cluster("clusterTwo", "amqp:child:2");
BOOST_REQUIRE(cluster.received.waitFor(1)); // Frame from parent.
BOOST_CHECK(cluster.received[0].isIncoming);
BOOST_CHECK_TYPEID_EQUAL(ChannelPingBody, *cluster.received[0].frame.getBody());
BOOST_CHECK_EQUAL(2u, cluster.size()); // Me and parent
AMQFrame frame(VER, 1, new ChannelOkBody(VER));
- Uuid id(true);
- SessionFrame sf(id, frame, false);
+ SessionFrame sf(cluster.received[0].uuid, frame, false);
cluster.handle(sf);
BOOST_REQUIRE(cluster.received.waitFor(2));
BOOST_CHECK(!cluster.received[1].isIncoming);