rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/RequeueOnClose.java
public void requeueInFlightConsumerAckNoCancel() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndConsumeSome(true, false);
    }
  }
//  in the unacked map and when that arrives RabbitMQ closes the channel
in the unacked map and when that arrives RabbitMQ closes the channel
in the unacked map and when that arrives RabbitMQ closes the channel
public void requeueInFlightConsumerAckNoCancel() throws Exception {
    for (int i = 0; i < 5; i++) {
      publishLotsAndConsumeSome(true, false);
    }
  }
public void requeueInFlightConsumerAckNoCancel ( ) throws Exception { for ( int i = 0 ; i < 5 ; i ++ ) { publishLotsAndConsumeSome ( true , false ) ; } }
in the unacked map and when that arrives RabbitMQ closes the channel
in the unacked map and when that arrives RabbitMQ closes the channel