Skip to content

Commit 478d572

Browse files
committed
cosmetic
and check for clustering in the same way as elsewhere, i.e. restart()
1 parent 8928b2b commit 478d572

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

test/src/com/rabbitmq/client/test/server/DurableBindingLifecycle.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -134,13 +134,14 @@ public void testDefaultBindingRecovery() throws IOException {
134134
}
135135

136136
/**
137-
* Test that when we have a transient exchange bound to a durable queue and the
138-
* durable queue is on a cluster node that restarts, we do not lose the binding.
139-
* See bug 24009.
137+
* Test that when we have a transient exchange bound to a durable
138+
* queue and the durable queue is on a cluster node that restarts,
139+
* we do not lose the binding. See bug 24009.
140140
*/
141141
public void testTransientExchangeDurableQueue() throws IOException {
142-
// This test depends on the second node in the cluster to keep the transient X alive
143-
if (clusteredChannel != null) {
142+
// This test depends on the second node in the cluster to keep
143+
// the transient X alive
144+
if (clusteredConnection != null) {
144145
channel.exchangeDeclare("transientX", "fanout", false);
145146
declareAndBindDurableQueue("durableQ", "transientX", "");
146147

0 commit comments

Comments
 (0)