@@ -88,19 +88,7 @@ private void basicAck()
8888 basicAck (latestTag , false );
8989 }
9090
91- private void basicNack (long tag , boolean multiple , boolean requeue )
92- throws IOException
93- {
94- channel .basicNack (tag , multiple , requeue );
95- }
96-
97- private void basicReject (long tag , boolean requeue )
98- throws IOException
99- {
100- channel .basicReject (tag , requeue );
101- }
102-
103- private abstract class GenericNack {
91+ private abstract class NackMethod {
10492 abstract public void nack (long tag , boolean requeue )
10593 throws IOException ;
10694
@@ -117,19 +105,19 @@ public void nack()
117105 }
118106 }
119107
120- private GenericNack genNack = new GenericNack () {
108+ private NackMethod basicNack = new NackMethod () {
121109 public void nack (long tag , boolean requeue )
122110 throws IOException
123111 {
124- basicNack (tag , false , requeue );
112+ channel . basicNack (tag , false , requeue );
125113 }
126114 };
127115
128- private GenericNack genReject = new GenericNack () {
116+ private NackMethod basicReject = new NackMethod () {
129117 public void nack (long tag , boolean requeue )
130118 throws IOException
131119 {
132- basicReject (tag , requeue );
120+ channel . basicReject (tag , requeue );
133121 }
134122 };
135123
@@ -379,34 +367,34 @@ public void testShuffleAcksBeforeRollback()
379367 messages with nacks get requeued after the transaction commit.
380368 messages with nacks with requeue = false are not requeued.
381369 */
382- public void commitNacks (GenericNack genNack )
370+ public void commitNacks (NackMethod method )
383371 throws IOException
384372 {
385373 basicPublish ();
386374 basicPublish ();
387375 txSelect ();
388376 basicGet ();
389- genNack .nack ();
377+ method .nack ();
390378 basicGet ();
391- genNack .nack (false );
379+ method .nack (false );
392380 assertNull (basicGet ());
393381 txCommit ();
394382 assertNotNull (basicGet ());
395383 assertNull (basicGet ());
396384 }
397385
398- public void rollbackNacks (GenericNack genNack )
386+ public void rollbackNacks (NackMethod method )
399387 throws IOException
400388 {
401389 basicPublish ();
402390 txSelect ();
403391 basicGet ();
404- genNack .nack (true );
392+ method .nack (true );
405393 txRollback ();
406394 assertNull (basicGet ());
407395 }
408396
409- public void commitAcksAndNacks (GenericNack genNack )
397+ public void commitAcksAndNacks (NackMethod method )
410398 throws IOException
411399 {
412400 for (int i = 0 ; i < 3 ; i ++) {
@@ -419,11 +407,11 @@ public void commitAcksAndNacks(GenericNack genNack)
419407 }
420408 basicAck (tags [1 ], false );
421409 basicAck (tags [0 ], false );
422- genNack .nack (tags [2 ], false );
410+ method .nack (tags [2 ], false );
423411 txRollback ();
424412 basicAck (tags [2 ], false );
425- genNack .nack (tags [0 ], true );
426- genNack .nack (tags [1 ], false );
413+ method .nack (tags [0 ], true );
414+ method .nack (tags [1 ], false );
427415 txCommit ();
428416 assertNotNull (basicGet ());
429417 assertNull (basicGet ());
@@ -432,36 +420,36 @@ public void commitAcksAndNacks(GenericNack genNack)
432420 public void testCommitNacks ()
433421 throws IOException
434422 {
435- commitNacks (genNack );
423+ commitNacks (basicNack );
436424 }
437425
438426 public void testRollbackNacks ()
439427 throws IOException
440428 {
441- rollbackNacks (genNack );
429+ rollbackNacks (basicNack );
442430 }
443431
444432 public void testCommitAcksAndNacks ()
445433 throws IOException
446434 {
447- commitAcksAndNacks (genNack );
435+ commitAcksAndNacks (basicNack );
448436 }
449437
450438 public void testCommitRejects ()
451439 throws IOException
452440 {
453- commitNacks (genReject );
441+ commitNacks (basicReject );
454442 }
455443
456444 public void testRollbackRejects ()
457445 throws IOException
458446 {
459- rollbackNacks (genReject );
447+ rollbackNacks (basicReject );
460448 }
461449
462450 public void testCommitAcksAndRejects ()
463451 throws IOException
464452 {
465- commitAcksAndNacks (genReject );
453+ commitAcksAndNacks (basicReject );
466454 }
467455}
0 commit comments