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


Constructor Summary
ProducerBrokerExchange()
           
 
Method Summary
 boolean canDispatch(Message messageSend)
          Enforce duplicate suppression using info from persistence adapter
 ProducerBrokerExchange copy()
           
 ConnectionContext getConnectionContext()
           
 ProducerState getProducerState()
           
 Region getRegion()
           
 Destination getRegionDestination()
           
 boolean isMutable()
           
 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

Parameters:
messageSend -
Returns:
false if message should be ignored as a duplicate

setLastStoredSequenceId

public void setLastStoredSequenceId(long l)


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.