Interface Destination

    • Field Detail

      • DEFAULT_DEAD_LETTER_STRATEGY

        static final DeadLetterStrategy DEFAULT_DEAD_LETTER_STRATEGY
      • DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL

        static final long DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL
        See Also:
        Constant Field Values
    • Method Detail

      • getInactiveTimeoutBeforeGC

        long getInactiveTimeoutBeforeGC()
      • markForGC

        void markForGC​(long timeStamp)
      • canGC

        boolean canGC()
      • gc

        void gc()
      • setMemoryUsage

        void setMemoryUsage​(MemoryUsage memoryUsage)
      • isDisposed

        boolean isDisposed()
      • isProducerFlowControl

        boolean isProducerFlowControl()
      • setProducerFlowControl

        void setProducerFlowControl​(boolean value)
      • isAlwaysRetroactive

        boolean isAlwaysRetroactive()
      • setAlwaysRetroactive

        void setAlwaysRetroactive​(boolean value)
      • setBlockedProducerWarningInterval

        void setBlockedProducerWarningInterval​(long blockedProducerWarningInterval)
        Set's the interval at which warnings about producers being blocked by resource usage will be triggered. Values of 0 or less will disable warnings
        Parameters:
        blockedProducerWarningInterval - the interval at which warning about blocked producers will be triggered.
      • getBlockedProducerWarningInterval

        long getBlockedProducerWarningInterval()
        Returns:
        the interval at which warning about blocked producers will be triggered.
      • getMaxProducersToAudit

        int getMaxProducersToAudit()
      • setMaxProducersToAudit

        void setMaxProducersToAudit​(int maxProducersToAudit)
      • getMaxAuditDepth

        int getMaxAuditDepth()
      • setMaxAuditDepth

        void setMaxAuditDepth​(int maxAuditDepth)
      • isEnableAudit

        boolean isEnableAudit()
      • setEnableAudit

        void setEnableAudit​(boolean enableAudit)
      • isActive

        boolean isActive()
      • getMaxPageSize

        int getMaxPageSize()
      • setMaxPageSize

        void setMaxPageSize​(int maxPageSize)
      • getMaxBrowsePageSize

        int getMaxBrowsePageSize()
      • setMaxBrowsePageSize

        void setMaxBrowsePageSize​(int maxPageSize)
      • isUseCache

        boolean isUseCache()
      • setUseCache

        void setUseCache​(boolean useCache)
      • setMinimumMessageSize

        void setMinimumMessageSize​(int minimumMessageSize)
      • getCursorMemoryHighWaterMark

        int getCursorMemoryHighWaterMark()
      • setCursorMemoryHighWaterMark

        void setCursorMemoryHighWaterMark​(int cursorMemoryHighWaterMark)
      • wakeup

        void wakeup()
        optionally called by a Subscriber - to inform the Destination its ready for more messages
      • isLazyDispatch

        boolean isLazyDispatch()
        Returns:
        true if lazyDispatch is enabled
      • setLazyDispatch

        void setLazyDispatch​(boolean value)
        set the lazy dispatch - default is false
        Parameters:
        value -
      • messageConsumed

        void messageConsumed​(ConnectionContext context,
                             MessageReference messageReference)
        called when message is consumed
        Parameters:
        context -
        messageReference -
      • messageDelivered

        void messageDelivered​(ConnectionContext context,
                              MessageReference messageReference)
        Called when message is delivered to the broker
        Parameters:
        context -
        messageReference -
      • messageDiscarded

        void messageDiscarded​(ConnectionContext context,
                              Subscription sub,
                              MessageReference messageReference)
        Called when a message is discarded - e.g. running low on memory This will happen only if the policy is enabled - e.g. non durable topics
        Parameters:
        context -
        messageReference -
        sub -
      • slowConsumer

        void slowConsumer​(ConnectionContext context,
                          Subscription subs)
        Called when there is a slow consumer
        Parameters:
        context -
        subs -
      • fastProducer

        void fastProducer​(ConnectionContext context,
                          ProducerInfo producerInfo)
        Called to notify a producer is too fast
        Parameters:
        context -
        producerInfo -
      • isFull

        void isFull​(ConnectionContext context,
                    Usage<?> usage)
        Called when a Usage reaches a limit
        Parameters:
        context -
        usage -
      • processDispatchNotification

        void processDispatchNotification​(MessageDispatchNotification messageDispatchNotification)
                                  throws Exception
        called on Queues in slave mode to allow dispatch to follow subscription choice of master
        Parameters:
        messageDispatchNotification -
        Throws:
        Exception
      • isPrioritizedMessages

        boolean isPrioritizedMessages()
      • isDoOptimzeMessageStorage

        boolean isDoOptimzeMessageStorage()
      • setDoOptimzeMessageStorage

        void setDoOptimzeMessageStorage​(boolean doOptimzeMessageStorage)
      • clearPendingMessages

        void clearPendingMessages​(int pendingAdditionsCount)
      • isSendDuplicateFromStoreToDLQ

        boolean isSendDuplicateFromStoreToDLQ()
      • setSendDuplicateFromStoreToDLQ

        void setSendDuplicateFromStoreToDLQ​(boolean sendDuplicateFromStoreToDLQ)