Module org.jooq
Package org.jooq.util.oracle

Class OracleDSL.DBMS_AQ

  • Enclosing class:
    OracleDSL
    public static final class OracleDSL.DBMS_AQ
extends Object
    Oracle AQ related features are located here.
    Author:
    Lukas Eder

    • Method Detail

      • enqueue

        public static <R extends UDTRecord<R>> void enqueue​(Configuration configuration,
                                                    Queue<R> queue,
                                                    R payload)
        Enqueue a message in an Oracle AQ.
        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        payload - The message payload.

      • dequeueIterable

        public static <R extends UDTRecord<R>> Iterable<R> dequeueIterable​(Configuration configuration,
                                                                   Queue<R> queue)
        Dequeue messages as an Oracle AQ Iterable.

        This returns an infinite Iterable of AQ messages. Messages are dequeued via individual calls to DBMS_AQ, so no resources are bound by the stream. The Iterator is blocking on the AQ until new messages are delivered.

        Individual dequeue calls run in a TransactionalCallable and are committed immediately. Use dequeue(Configuration, Queue) instead, if you want to commit / rollback individual messages.

        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        Returns:
        The message payload.

      • dequeueStream

        public static <R extends UDTRecord<R>> Stream<R> dequeueStream​(Configuration configuration,
                                                               Queue<R> queue)
        Dequeue messages as an Oracle AQ Stream.

        This returns an infinite Stream of AQ messages. Messages are dequeued via individual calls to DBMS_AQ, so no resources are bound by the stream. The stream is blocking on the AQ until new messages are delivered.

        Individual dequeue calls run in a TransactionalCallable and are committed immediately. Use dequeue(Configuration, Queue) instead, if you want to commit / rollback individual messages.

        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        Returns:
        The message payload.

      • dequeueStream

        public static <R extends UDTRecord<R>> Stream<R> dequeueStream​(Configuration configuration,
                                                               Queue<R> queue,
                                                               OracleDSL.DBMS_AQ.DEQUEUE_OPTIONS_T options)
        Dequeue messages as an Oracle AQ Stream.

        This returns an infinite Stream of AQ messages. Messages are dequeued via individual calls to DBMS_AQ, so no resources are bound by the stream. The stream is blocking on the AQ until new messages are delivered.

        Individual dequeue calls run in a TransactionalCallable and are committed immediately. Use dequeue(Configuration, Queue, DEQUEUE_OPTIONS_T) instead, if you want to commit / rollback individual messages.

        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        options - The dequeue options.
        Returns:
        The message payload.

      • dequeueAsync

        public static <R extends UDTRecord<R>> CompletionStage<R> dequeueAsync​(Executor executor,
                                                                       Configuration configuration,
                                                                       Queue<R> queue)
        Dequeue a message in an Oracle AQ, asynchronously in the given executor.

        The dequeue operation will happen in a (nested) transaction. In order to control transaction behaviour, supply a Configuration with appropriate TransactionProvider.

        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        Returns:
        The message payload.

      • dequeueAsync

        public static <R extends UDTRecord<R>> CompletionStage<R> dequeueAsync​(Executor executor,
                                                                       Configuration configuration,
                                                                       Queue<R> queue,
                                                                       OracleDSL.DBMS_AQ.DEQUEUE_OPTIONS_T options)
        Dequeue a message in an Oracle AQ, asynchronously in the given executor.

        The dequeue operation will happen in a (nested) transaction. In order to control transaction behaviour, supply a Configuration with appropriate TransactionProvider.

        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        options - The dequeue options.
        Returns:
        The message payload.

      • dequeue

        public static <R extends UDTRecord<R>> R dequeue​(Configuration configuration,
                                                 Queue<R> queue)
        Dequeue a message in an Oracle AQ.
        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        Returns:
        The message payload.

      • dequeue

        public static <R extends UDTRecord<R>> R dequeue​(Configuration configuration,
                                                 Queue<R> queue,
                                                 OracleDSL.DBMS_AQ.DEQUEUE_OPTIONS_T options)
        Dequeue a message in an Oracle AQ.
        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        options - The dequeue options.
        Returns:
        The message payload.

      • dequeue

        public static <R extends UDTRecord<R>> R dequeue​(Configuration configuration,
                                                 Queue<R> queue,
                                                 OracleDSL.DBMS_AQ.DEQUEUE_OPTIONS_T options,
                                                 OracleDSL.DBMS_AQ.MESSAGE_PROPERTIES_T properties)
        Dequeue a message in an Oracle AQ.
        Parameters:
        configuration - The configuration from which to get a connection.
        queue - The queue reference.
        options - The dequeue options.
        properties - The message properties OUT parameter. Resulting values will be stored here.
        Returns:
        The message payload.