Interface QueueMBean

    • Method Detail

      • getThreshold

        int getThreshold()
        Returns the threshold value of this queue, -1 if not set.
        Returns:
        the threshold value of this queue; -1 if not set.
      • setThreshold

        void setThreshold​(int threshold)
        Sets or unsets the threshold for this queue.
        Parameters:
        threshold - The threshold value to be set or -1 for unsetting previous value.
      • getWaitingRequestCount

        int getWaitingRequestCount()
        Returns the number of waiting requests in the queue.
        Returns:
        The number of waiting requests.
      • cleanWaitingRequest

        void cleanWaitingRequest()
                          throws Exception
        Removes all request that the expiration time is expired.
        Throws:
        Exception
      • getPendingMessageCount

        int getPendingMessageCount()
        Returns the number of pending messages in the queue.
        Returns:
        The number of pending messages.
      • getDelayedMessageCount

        int getDelayedMessageCount()
        Returns the number of messages waiting for a delay.
        Returns:
        The number of messages waiting for a delay.
      • getProducerLoad

        long getProducerLoad()
        Return the average producer's load during last moments.
      • getConsumerLoad

        long getConsumerLoad()
        Return the average consumer's load during last moments.
      • cleanPendingMessage

        void cleanPendingMessage()
                          throws Exception
        Removes all messages that the time-to-live is expired.
        Throws:
        Exception
      • getDeliveredMessageCount

        int getDeliveredMessageCount()
        Returns the number of messages delivered and waiting for acknowledge.
        Returns:
        The number of messages delivered.
      • getNbMsgsDeniedSinceCreation

        long getNbMsgsDeniedSinceCreation()
        Returns the number of messages denied since creation time of this destination.
        Returns:
        the number of messages delivered since creation time.
      • getNbMaxMsg

        int getNbMaxMsg()
        Returns the maximum number of message for the destination. If the limit is unset the method returns -1.
        Returns:
        the maximum number of message for subscription if set; -1 otherwise.
      • setNbMaxMsg

        void setNbMaxMsg​(int nbMaxMsg)
        Sets the maximum number of message for the destination.
        Parameters:
        nbMaxMsg - the maximum number of message (-1 set no limit).
      • getMessage

        CompositeData getMessage​(String msgId)
                          throws Exception
        Returns the description of a particular pending message. The message is pointed out through its unique identifier.
        Parameters:
        msgId - The unique message's identifier.
        Returns:
        the description of the message.
        Throws:
        Exception
        See Also:
        MessageJMXWrapper
      • getDelayedMessage

        CompositeData getDelayedMessage​(String msgId)
                                 throws Exception
        Returns the description of a particular delayed message. The message is pointed out through its unique identifier.
        Parameters:
        msgId - The unique message's identifier.
        Returns:
        the description of the message.
        Throws:
        Exception
        See Also:
        MessageJMXWrapper
      • getRedeliveryDelay

        int getRedeliveryDelay()
        Return the reDeliveryDelay (unit: second)
      • setRedeliveryDelay

        void setRedeliveryDelay​(int reDeliveryDelay)
        Parameters:
        reDeliveryDelay - the reDeliveryDelay to set(unit: second)
      • getDeliveryDelay

        int getDeliveryDelay()
        Returns the Queue deliveryDelay in milliseconds.
        Returns:
        the DeliveryDelay
      • setDeliveryDelay

        void setDeliveryDelay​(int deliveryDelay)
        Sets the Queue deliveryDelay in milliseconds.
        Parameters:
        deliveryDelay - the deliveryDelay to set
      • isPause

        boolean isPause()
      • setPause

        void setPause​(boolean pause)
      • exportMessages

        void exportMessages​(String dirpath,
                            String selector,
                            boolean quiet)
                     throws Exception
        Exports all messages in the specified directory. Options? filtrage? Format?
        Throws:
        Exception
      • clear

        void clear()
        Removes all pending messages.