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