File tree Expand file tree Collapse file tree 1 file changed +15
-24
lines changed
test/src/com/rabbitmq/client/test/functional Expand file tree Collapse file tree 1 file changed +15
-24
lines changed Original file line number Diff line number Diff line change @@ -347,30 +347,21 @@ public void testShuffleAcksBeforeRollback()
347347 throws IOException
348348 {
349349 openChannel ();
350- try {
351- createResources ();
352- for (int i = 0 ; i < 3 ; i ++) {
353- basicPublish ();
354- }
355- txSelect ();
356- long tags [] = new long [3 ];
357- for (int i = 0 ; i < 3 ; i ++) {
358- tags [i ] = basicGet ().getEnvelope ().getDeliveryTag ();
359- }
360- basicAck (tags [2 ], false );
361- basicAck (tags [1 ], false );
362- txRollback ();
363- basicAck (tags [0 ], true );
364- basicAck (tags [1 ], false );
365- basicAck (tags [2 ], false );
366- txCommit ();
367- } catch (IOException e ) {
368- closeConnection ();
369- openConnection ();
370- openChannel ();
371- throw e ;
372- } finally {
373- closeChannel ();
350+ createResources ();
351+ for (int i = 0 ; i < 3 ; i ++) {
352+ basicPublish ();
374353 }
354+ txSelect ();
355+ long tags [] = new long [3 ];
356+ for (int i = 0 ; i < 3 ; i ++) {
357+ tags [i ] = basicGet ().getEnvelope ().getDeliveryTag ();
358+ }
359+ basicAck (tags [2 ], false );
360+ basicAck (tags [1 ], false );
361+ txRollback ();
362+ basicAck (tags [0 ], true );
363+ basicAck (tags [1 ], false );
364+ basicAck (tags [2 ], false );
365+ txCommit ();
375366 }
376367}
You can’t perform that action at this time.
0 commit comments