org.apache.activemq.broker
Class ProducerBrokerExchange
java.lang.Object
org.apache.activemq.broker.ProducerBrokerExchange
public class ProducerBrokerExchange
- extends java.lang.Object
Holds internal state in the broker for a MessageProducer
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProducerBrokerExchange
public ProducerBrokerExchange()
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
- Parameters:
messageSend
-
- Returns:
- false if message should be ignored as a duplicate
setLastStoredSequenceId
public void setLastStoredSequenceId(long l)
Copyright © 2005-2012. All Rights Reserved.