BEGIN
  DBMS_AQADM.CREATE_QUEUE_TABLE(
    queue_table => 'new_author_aq_t',
    queue_payload_type => 'author_t'
  );

  DBMS_AQADM.CREATE_QUEUE(
    queue_name => 'new_author_aq',
    queue_table => 'new_author_aq_t'
  );

  DBMS_AQADM.START_QUEUE(
    queue_name => 'new_author_aq'
  );
  COMMIT;
END;
/

@javax.annotation.Generated(value    = { "http://www.jooq.org", "3.5.0" },
                            comments = "This class is generated by jOOQ")
@java.lang.SuppressWarnings({ "all", "unchecked", "rawtypes" })
public class Queues {

    /**
     * The queue <code>SP.NEW_AUTHOR_AQ</code>
     */
    public static final Queue<AuthorTRecord> NEW_AUTHOR_AQ = 
        new QueueImpl<AuthorTRecord>("NEW_AUTHOR_AQ", SP, AUTHOR_T);
}

    @Test
    public void testAQ() {
        AuthorTRecord payload = new AuthorTRecord();
        payload.setFirstName("Paulo");
        payload.setLastName("Coelho");
        DBMS_AQ.enqueue(dsl.configuration(), NEW_AUTHOR_AQ, payload);

        for (int i = 0; i < 10; i++) {
            // Blocking call here:
            AuthorTRecord author = DBMS_AQ.dequeue(dsl.configuration(), NEW_AUTHOR_AQ);

            System.out.println(author);
            BooksTRecord books = author.getBooks();
            if (books != null)
                for (BookTRecord book : books.get())
                    System.out.println(book);
        }
    }

@Test
public void testAQSimple() throws Exception {

    // Enqueue all authors
    authors.stream().forEach(a -> {
        DBMS_AQ.enqueue(dsl.configuration(), NEW_AUTHOR_AQ, a);
    });

    // Dequeue them again
    authors.stream().forEach(a -> {
        assertEquals(a, DBMS_AQ.dequeue(dsl.configuration(), NEW_AUTHOR_AQ));
    });
}

@Test
public void testAQTransactions() throws Exception {
    dsl.transaction((ctx) -> {

        ENQUEUE_OPTIONS_T enq = new ENQUEUE_OPTIONS_T().visibility(IMMEDIATE);

        // Enqueue two authors
        DBMS_AQ.enqueue(dsl.configuration(), NEW_AUTHOR_AQ, authors.get(0), enq);
        DBMS_AQ.enqueue(dsl.configuration(), NEW_AUTHOR_AQ, authors.get(1), enq);

        // Dequeue them again
        DEQUEUE_OPTIONS_T deq = new DEQUEUE_OPTIONS_T().wait(NO_WAIT);

        assertEquals(authors.get(0), DBMS_AQ.dequeue(dsl.configuration(), NEW_AUTHOR_AQ, deq));
        assertEquals(authors.get(1), DBMS_AQ.dequeue(dsl.configuration(), NEW_AUTHOR_AQ, deq));

        // The queue is empty, this should fail
        assertThrows(DataAccessException.class, () -> {
            DBMS_AQ.dequeue(dsl.configuration(), NEW_AUTHOR_AQ, deq);
        });
    });
}