Class CompositeQueue

    • Method Detail

      • lockQueue

        public void lockQueue​(java.lang.Object object)
        Description copied from class: AbstractQueue
        Locks this queue and holds it until unlockQueue is called.
        Overrides:
        lockQueue in class AbstractQueue
        Parameters:
        object - local transactionId
      • unlockQueue

        public void unlockQueue​(java.lang.Object object,
                                boolean markAsyncActive)
        Description copied from class: AbstractQueue
        Unlocks this queue.
        Overrides:
        unlockQueue in class AbstractQueue
        Parameters:
        object - local transactionId
        markAsyncActive - blocks queue as async is active
      • setCompositeStoreTransaction

        public void setCompositeStoreTransaction​(java.lang.Object object,
                                                 CompositeStoreTransaction ct)
        Description copied from class: AbstractQueue
        Sets a CompositeStoreTransaction to be used as the current transaction. At the same time it disables prepare/commit/rollback calls inside this queue so that multiple queues can use the same transaction and prepare/commit/rollback is done outside.
        Overrides:
        setCompositeStoreTransaction in class AbstractQueue
        Parameters:
        object - local transactionId
        ct - composite transaction
      • hasReceiver

        public boolean hasReceiver​(MessageImpl message)
        Description copied from class: AbstractQueue
        Checks all registered receivers and, if set, their message selectors whether this message will be received by one of them.
        Specified by:
        hasReceiver in class AbstractQueue
        Returns:
        has receiver or not
      • prepare

        public void prepare​(java.lang.Object object,
                            XidImpl xid)
                     throws QueueException
        Description copied from class: AbstractQueue
        Prepares the transaction with the given transaction id. Messages are stored in the queue (on disk when persistent) but not unlocked. The preparation is logged under the global transaction id.
        Specified by:
        prepare in class AbstractQueue
        Parameters:
        object - local transaction id
        xid - global transaction id
        Throws:
        QueueException - on error
      • commit

        public void commit​(java.lang.Object object,
                           AsyncCompletionCallback callback)
        Description copied from class: AbstractQueue
        Asynchronously commits the transaction with the given transaction id
        Specified by:
        commit in class AbstractQueue
        Parameters:
        object - transaction id
        callback - async completion callback
      • rollback

        public void rollback​(java.lang.Object object,
                             XidImpl xid,
                             boolean setRedelivered)
                      throws QueueException
        Description copied from class: AbstractQueue
        Rolls back the transaction with the given transaction id, eventually prepared under a global transaction id. If the flag setRedelivered is set then the JMS properties for redelivery and delivery count of messages pulled within this transaction are updated.
        Specified by:
        rollback in class AbstractQueue
        Parameters:
        object - transaction id
        xid - global transaction id
        setRedelivered - specifies JMS redelivery setting
        Throws:
        QueueException - on error
      • rollback

        public void rollback​(java.lang.Object object,
                             boolean setRedelivered)
                      throws QueueException
        Description copied from class: AbstractQueue
        Rolls back the transaction with the given transaction id. If the flag setRedelivered is set then the JMS properties for redelivery and delivery count of messages pulled within this transaction are updated
        Specified by:
        rollback in class AbstractQueue
        Parameters:
        object - transaction id
        setRedelivered - specifies JMS redelivery setting
        Throws:
        QueueException - on error
      • rollback

        public void rollback​(java.lang.Object object,
                             boolean setRedelivered,
                             AsyncCompletionCallback callback)
        Description copied from class: AbstractQueue
        Asynchronously rolls back the transaction with the given transaction id. If the flag setRedelivered is set then the JMS properties for redelivery and delivery count of messages pulled within this transaction are updated
        Specified by:
        rollback in class AbstractQueue
        Parameters:
        object - transaction id
        setRedelivered - specifies JMS redelivery setting
        callback - async completion callback