rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/RequeueOnClose.java
@Test
  public void requeueInFlight() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndGet();
    }
  }
/**
   * Test close while consuming many messages successfully requeues unacknowledged messages
   *
   * @throws Exception untested
   */
Test close while consuming many messages successfully requeues unacknowledged messages
@throws Exception untested
Test close while consuming many messages successfully requeues unacknowledged messages @throws Exception untested
@Test
  public void requeueInFlight() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndGet();
    }
  }
@ Test public void requeueInFlight ( ) throws Exception { for ( int i = 0 ; i < 5 ; i ++ ) { publishLotsAndGet ( ) ; } }
Test close while consuming many messages successfully requeues unacknowledged messages
 @throws Exception untested
Test close while consuming many messages successfully requeues unacknowledged messages @throws Exception untested