Package org.apache.activemq.broker

Class ProducerBrokerExchange

  • public class ProducerBrokerExchange
extends Object
    Holds internal state in the broker for a MessageProducer

    • Constructor Detail

      • ProducerBrokerExchange

        public ProducerBrokerExchange()

    • Method Detail

      • getConnectionContext

        public ConnectionContext getConnectionContext()
        Returns:
        the connectionContext

      • setConnectionContext

        public void setConnectionContext​(ConnectionContext connectionContext)
        Parameters:
        connectionContext - the connectionContext to set

      • isMutable

        public boolean isMutable()
        Returns:
        the mutable

      • setMutable

        public void setMutable​(boolean mutable)
        Parameters:
        mutable - the mutable to set

      • getRegionDestination

        public Destination getRegionDestination()
        Returns:
        the regionDestination

      • setRegionDestination

        public void setRegionDestination​(Destination regionDestination)
        Parameters:
        regionDestination - the regionDestination to set

      • getRegion

        public Region getRegion()
        Returns:
        the region

      • setRegion

        public void setRegion​(Region region)
        Parameters:
        region - the region to set

      • getProducerState

        public ProducerState getProducerState()
        Returns:
        the producerState

      • setProducerState

        public void setProducerState​(ProducerState producerState)
        Parameters:
        producerState - the producerState to set

      • canDispatch

        public boolean canDispatch​(Message messageSend)
        Enforce duplicate suppression using info from persistence adapter
        Returns:
        false if message should be ignored as a duplicate

      • setLastStoredSequenceId

        public void setLastStoredSequenceId​(long l)

      • incrementSend

        public void incrementSend()

      • blockingOnFlowControl

        public void blockingOnFlowControl​(boolean blockingOnFlowControl)

      • incrementTimeBlocked

        public void incrementTimeBlocked​(Destination destination,
                                 long timeBlocked)

      • isBlockedForFlowControl

        public boolean isBlockedForFlowControl()

      • resetFlowControl

        public void resetFlowControl()

      • getTotalTimeBlocked

        public long getTotalTimeBlocked()

      • getPercentageBlocked

        public int getPercentageBlocked()