rabbitmq-tests/src/test/java/com/datastax/oss/starlight/rabbitmqtests/javaclient/functional/RequeueOnClose.java
@Test
  public void requeueingConsumer() throws Exception {
    openConnection();
    open();
    injectMessage();
    QueueingConsumer c = new QueueingConsumer(channel);
    channel.basicConsume(Q, c);
    c.nextDelivery();
    close();
    open();
    assertNotNull(getMessage());
    close();
    closeConnection();
  }
/**
   * Test we requeue unacknowledged message (using consumer)
   *
   * @throws Exception untested
   */
Test we requeue unacknowledged message (using consumer)
@throws Exception untested
Test we requeue unacknowledged message ( using consumer ) @throws Exception untested
@Test
  public void requeueingConsumer() throws Exception {
    openConnection();
    open();
    injectMessage();
    QueueingConsumer c = new QueueingConsumer(channel);
    channel.basicConsume(Q, c);
    c.nextDelivery();
    close();
    open();
    assertNotNull(getMessage());
    close();
    closeConnection();
  }
@ Test public void requeueingConsumer ( ) throws Exception { openConnection ( ) ; open ( ) ; injectMessage ( ) ; QueueingConsumer c = new QueueingConsumer ( channel ) ; channel . basicConsume ( Q , c ) ; c . nextDelivery ( ) ; close ( ) ; open ( ) ; assertNotNull ( getMessage ( ) ) ; close ( ) ; closeConnection ( ) ; }
Test we requeue unacknowledged message (using consumer)
 @throws Exception untested
Test we requeue unacknowledged message ( using consumer ) @throws Exception untested