org.apache.activemq.broker
Class ProducerBrokerExchange

java.lang.Object
  extended by org.apache.activemq.broker.ProducerBrokerExchange

public class ProducerBrokerExchange
extends Object

Holds internal state in the broker for a MessageProducer


Nested Class Summary
static class ProducerBrokerExchange.FlowControlInfo
           
 
Constructor Summary
ProducerBrokerExchange()
           
 
Method Summary
 void blockingOnFlowControl(boolean blockingOnFlowControl)
           
 boolean canDispatch(Message messageSend)
          Enforce duplicate suppression using info from persistence adapter
 ProducerBrokerExchange copy()
           
 ConnectionContext getConnectionContext()
           
 int getPercentageBlocked()
           
 ProducerState getProducerState()
           
 Region getRegion()
           
 Destination getRegionDestination()
           
 long getTotalTimeBlocked()
           
 void incrementSend()
           
 void incrementTimeBlocked(Destination destination, long timeBlocked)
           
 boolean isBlockedForFlowControl()
           
 boolean isMutable()
           
 void resetFlowControl()
           
 void setConnectionContext(ConnectionContext connectionContext)
           
 void setLastStoredSequenceId(long l)
           
 void setMutable(boolean mutable)
           
 void setProducerState(ProducerState producerState)
           
 void setRegion(Region region)
           
 void setRegionDestination(Destination regionDestination)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ProducerBrokerExchange

public ProducerBrokerExchange()
Method Detail

copy

public ProducerBrokerExchange copy()

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()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.