rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/BindingLifecycle.java
@Test
  @Ignore("Need to implement queue purge first")
  public void queuePurge() throws IOException {

    Binding binding = setupExchangeBindings(false);
    channel.basicPublish(binding.x, binding.k, null, payload);

    // Purge the queue, and test that we don't receive a message
    channel.queuePurge(binding.q);

    GetResponse response = TestUtils.basicGet(channel, binding.q, true);
    assertNull("The response SHOULD BE null", response);

    deleteExchangeAndQueue(binding);
  }
/** This tests that when you purge a queue, all of its messages go. */
This tests that when you purge a queue, all of its messages go.
This tests that when you purge a queue all of its messages go .
@Test
  @Ignore("Need to implement queue purge first")
  public void queuePurge() throws IOException {
    Binding binding = setupExchangeBindings(false);
    channel.basicPublish(binding.x, binding.k, null, payload);
    channel.queuePurge(binding.q);
    GetResponse response = TestUtils.basicGet(channel, binding.q, true);
    assertNull("The response SHOULD BE null", response);
    deleteExchangeAndQueue(binding);
  }
@ Test @ Ignore ( "Need to implement queue purge first" ) public void queuePurge ( ) throws IOException { Binding binding = setupExchangeBindings ( false ) ; channel . basicPublish ( binding . x , binding . k , null , payload ) ; channel . queuePurge ( binding . q ) ; GetResponse response = TestUtils . basicGet ( channel , binding . q , true ) ; assertNull ( "The response SHOULD BE null" , response ) ; deleteExchangeAndQueue ( binding ) ; }
This tests that when you purge a queue, all of its messages go.
This tests that when you purge a queue all of its messages go .
// Purge the queue, and test that we don't receive a message