rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/RequeueOnClose.java
@Test
  public void requeueInFlightConsumerNoAck() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndConsumeSome(false, true);
    }
  }
/**
   * Test close while consuming partially not acked with cancel successfully requeues unacknowledged
   * messages
   *
   * @throws Exception untested
   */
Test close while consuming partially not acked with cancel successfully requeues unacknowledged
messages

@throws Exception untested
Test close while consuming partially not acked with cancel successfully requeues unacknowledged messages @throws Exception untested
@Test
  public void requeueInFlightConsumerNoAck() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndConsumeSome(false, true);
    }
  }
@ Test public void requeueInFlightConsumerNoAck ( ) throws Exception { for ( int i = 0 ; i < 5 ; i ++ ) { publishLotsAndConsumeSome ( false , true ) ; } }
Test close while consuming partially not acked with cancel successfully requeues unacknowledged
 messages
Test close while consuming partially not acked with cancel successfully requeues unacknowledged messages