rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/Confirm.java
public void confirmTest(String exchange, String queueName, boolean persistent, boolean mandatory)
      throws IOException, InterruptedException, TimeoutException {
    publishN(exchange, queueName, persistent, mandatory);

    channel.waitForConfirmsOrDie(60000);
  }
/* Publish NUM_MESSAGES messages and wait for confirmations. */
Publish NUM_MESSAGES messages and wait for confirmations.
Publish NUM_MESSAGES messages and wait for confirmations .
public void confirmTest(String exchange, String queueName, boolean persistent, boolean mandatory)
      throws IOException, InterruptedException, TimeoutException {
    publishN(exchange, queueName, persistent, mandatory);
    channel.waitForConfirmsOrDie(60000);
  }
public void confirmTest ( String exchange , String queueName , boolean persistent , boolean mandatory ) throws IOException , InterruptedException , TimeoutException { publishN ( exchange , queueName , persistent , mandatory ) ; channel . waitForConfirmsOrDie ( 60000 ) ; }
Publish NUM_MESSAGES messages and wait for confirmations.
Publish NUM_MESSAGES messages and wait for confirmations .