Skip to content

Commit 95fdaca

Browse files
committed
simpler way to test confirmSelect idempotence
1 parent a5a75b8 commit 95fdaca

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

test/src/com/rabbitmq/client/test/functional/Confirm.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ public void testBasicRecover()
187187
public void testSelect()
188188
throws IOException
189189
{
190+
channel.confirmSelect();
190191
try {
191192
Channel ch = connection.createChannel();
192193
ch.confirmSelect();
@@ -203,9 +204,6 @@ public void testSelect()
203204
} catch (IOException ioe) {
204205
checkShutdownSignal(AMQP.PRECONDITION_FAILED, ioe);
205206
}
206-
Channel ch = connection.createChannel();
207-
ch.confirmSelect();
208-
ch.confirmSelect();
209207
}
210208

211209
/* Publish NUM_MESSAGES messages and wait for confirmations. */

0 commit comments

Comments
 (0)