Uses of Class
org.apache.activemq.broker.ConnectionContext

Packages that use ConnectionContext
org.apache.activemq.advisory Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available. 
org.apache.activemq.broker The core classes for the ActiveMQ Message Broker and its connectors. 
org.apache.activemq.broker.cluster   
org.apache.activemq.broker.ft Helper classes for implementing fault tolerance 
org.apache.activemq.broker.jmx JMX MBeans for the broker and its core connectors. 
org.apache.activemq.broker.region Region abstraction and implementations in the Broker. 
org.apache.activemq.broker.region.cursors Cursors used to page persistent messages into the broker from the store 
org.apache.activemq.broker.region.policy The policies which can be associated with a particular destination or wildcard. 
org.apache.activemq.broker.region.virtual Implementation classes for Virtual Destinations 
org.apache.activemq.broker.scheduler   
org.apache.activemq.broker.util Some utility Broker Plugins 
org.apache.activemq.broker.view Broker Plugins for visualising the current system 
org.apache.activemq.plugin   
org.apache.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation. 
org.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
org.apache.activemq.store.amq The default Store implementation for ActiveMQ 
org.apache.activemq.store.jdbc Message persistence implemented using JDBC 
org.apache.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface. 
org.apache.activemq.store.kahadaptor kaha implementation of message persistence for the broker 
org.apache.activemq.store.kahadb   
org.apache.activemq.store.memory VM based implementation of message persistence 
org.apache.activemq.transaction   
org.apache.activemq.util Some utility classes 
 

Uses of ConnectionContext in org.apache.activemq.advisory
 

Methods in org.apache.activemq.advisory with parameters of type ConnectionContext
 void AdvisoryBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 Subscription AdvisoryBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination AdvisoryBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
           
 void AdvisoryBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void AdvisoryBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 void AdvisoryBroker.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
protected  void AdvisoryBroker.fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command)
           
protected  void AdvisoryBroker.fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
           
protected  void AdvisoryBroker.fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId, ActiveMQMessage advisoryMessage)
           
protected  void AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command)
           
protected  void AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
           
protected  void AdvisoryBroker.fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command)
           
protected  void AdvisoryBroker.fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId)
           
 void AdvisoryBroker.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void AdvisoryBroker.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void AdvisoryBroker.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void AdvisoryBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void AdvisoryBroker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void AdvisoryBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void AdvisoryBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void AdvisoryBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void AdvisoryBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo destInfo)
           
 void AdvisoryBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void AdvisoryBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void AdvisoryBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 

Uses of ConnectionContext in org.apache.activemq.broker
 

Methods in org.apache.activemq.broker that return ConnectionContext
 ConnectionContext ConnectionContext.copy()
           
 ConnectionContext MutableBrokerFilter.getAdminConnectionContext()
           
 ConnectionContext ErrorBroker.getAdminConnectionContext()
           
 ConnectionContext EmptyBroker.getAdminConnectionContext()
           
 ConnectionContext BrokerService.getAdminConnectionContext()
          Returns the broker's administration connection context used for configuring the broker at startup
 ConnectionContext BrokerFilter.getAdminConnectionContext()
           
 ConnectionContext Broker.getAdminConnectionContext()
           
 ConnectionContext ProducerBrokerExchange.getConnectionContext()
           
 ConnectionContext ConsumerBrokerExchange.getConnectionContext()
           
 ConnectionContext TransportConnectionState.getContext()
           
 

Methods in org.apache.activemq.broker with parameters of type ConnectionContext
 void MutableBrokerFilter.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void ErrorBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void EmptyBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void BrokerFilter.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void BrokerBroadcaster.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void Broker.addConnection(ConnectionContext context, ConnectionInfo info)
          A client is establishing a connection with the broker.
 Subscription MutableBrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription ErrorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription EmptyBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerBroadcaster.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination MutableBrokerFilter.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
           
 Destination ErrorBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)
           
 Destination EmptyBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean flag)
           
 Destination BrokerFilter.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
           
 Destination BrokerBroadcaster.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
           
 void MutableBrokerFilter.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void ErrorBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void EmptyBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void BrokerFilter.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void Broker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
          Add and process a DestinationInfo object
 void MutableBrokerFilter.addProducer(ConnectionContext context, ProducerInfo info)
           
 void ErrorBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 void EmptyBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 void CompositeDestinationBroker.addProducer(ConnectionContext context, ProducerInfo info)
          A producer may register to send to multiple destinations via a composite destination.
 void BrokerFilter.addProducer(ConnectionContext context, ProducerInfo info)
           
 void BrokerBroadcaster.addProducer(ConnectionContext context, ProducerInfo info)
           
 void Broker.addProducer(ConnectionContext context, ProducerInfo info)
          Adds a producer.
 void MutableBrokerFilter.addSession(ConnectionContext context, SessionInfo info)
           
 void ErrorBroker.addSession(ConnectionContext context, SessionInfo info)
           
 void EmptyBroker.addSession(ConnectionContext context, SessionInfo info)
           
 void BrokerFilter.addSession(ConnectionContext context, SessionInfo info)
           
 void BrokerBroadcaster.addSession(ConnectionContext context, SessionInfo info)
           
 void Broker.addSession(ConnectionContext context, SessionInfo info)
          Adds a session.
 void TransactionBroker.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void MutableBrokerFilter.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void ErrorBroker.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void EmptyBroker.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void BrokerFilter.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void BrokerBroadcaster.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void Broker.beginTransaction(ConnectionContext context, TransactionId xid)
          Starts a transaction.
 void TransactionBroker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void MutableBrokerFilter.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void ErrorBroker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void EmptyBroker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void BrokerFilter.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void BrokerBroadcaster.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void Broker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
          Commits a transaction.
 void MutableBrokerFilter.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
 void ErrorBroker.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
 void EmptyBroker.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
 void BrokerFilter.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
 void Broker.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
          Called to notify a producer is too fast
 void TransactionBroker.forgetTransaction(ConnectionContext context, TransactionId xid)
           
 void MutableBrokerFilter.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 void ErrorBroker.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 void EmptyBroker.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 void BrokerFilter.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 void BrokerBroadcaster.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 void Broker.forgetTransaction(ConnectionContext context, TransactionId transactionId)
          Forgets a transaction.
 TransactionId[] TransactionBroker.getPreparedTransactions(ConnectionContext context)
           
 TransactionId[] MutableBrokerFilter.getPreparedTransactions(ConnectionContext context)
           
 TransactionId[] ErrorBroker.getPreparedTransactions(ConnectionContext context)
           
 TransactionId[] EmptyBroker.getPreparedTransactions(ConnectionContext context)
           
 TransactionId[] BrokerFilter.getPreparedTransactions(ConnectionContext context)
           
 TransactionId[] Broker.getPreparedTransactions(ConnectionContext context)
          Gets a list of all the prepared xa transactions.
 Transaction TransactionBroker.getTransaction(ConnectionContext context, TransactionId xid, boolean mightBePrepared)
           
 void MutableBrokerFilter.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void ErrorBroker.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void EmptyBroker.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void BrokerFilter.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void Broker.isFull(ConnectionContext context, Destination destination, Usage usage)
          Called when a Usage reaches a limit
 void MutableBrokerFilter.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void ErrorBroker.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void EmptyBroker.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void BrokerFilter.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void Broker.messageConsumed(ConnectionContext context, MessageReference messageReference)
          called when message is consumed
 void MutableBrokerFilter.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void ErrorBroker.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void EmptyBroker.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void BrokerFilter.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void Broker.messageDelivered(ConnectionContext context, MessageReference messageReference)
          Called when message is delivered to the broker
 void MutableBrokerFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void ErrorBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void EmptyBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void BrokerFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void Broker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void MutableBrokerFilter.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void ErrorBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void EmptyBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void BrokerFilter.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void Broker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
          A Message has Expired
 Response MutableBrokerFilter.messagePull(ConnectionContext context, MessagePull pull)
           
 Response ErrorBroker.messagePull(ConnectionContext context, MessagePull pull)
           
 Response EmptyBroker.messagePull(ConnectionContext context, MessagePull pull)
           
 Response BrokerFilter.messagePull(ConnectionContext context, MessagePull pull)
           
 int TransactionBroker.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int MutableBrokerFilter.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int ErrorBroker.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int EmptyBroker.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int BrokerFilter.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int BrokerBroadcaster.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int Broker.prepareTransaction(ConnectionContext context, TransactionId xid)
          Prepares a transaction.
 void TransactionBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void MutableBrokerFilter.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void ErrorBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void EmptyBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void BrokerFilter.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void BrokerBroadcaster.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void Broker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
          A client is disconnecting from the broker.
 void MutableBrokerFilter.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ErrorBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void EmptyBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void BrokerFilter.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void BrokerBroadcaster.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void MutableBrokerFilter.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ErrorBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void EmptyBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void BrokerFilter.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void BrokerBroadcaster.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void MutableBrokerFilter.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void ErrorBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void EmptyBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void BrokerFilter.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void Broker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
          Remove and process a DestinationInfo object
 void MutableBrokerFilter.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void ErrorBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void EmptyBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void CompositeDestinationBroker.removeProducer(ConnectionContext context, ProducerInfo info)
          A producer may de-register from sending to multiple destinations via a composite destination.
 void BrokerFilter.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void BrokerBroadcaster.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void Broker.removeProducer(ConnectionContext context, ProducerInfo info)
          Removes a producer.
 void MutableBrokerFilter.removeSession(ConnectionContext context, SessionInfo info)
           
 void ErrorBroker.removeSession(ConnectionContext context, SessionInfo info)
           
 void EmptyBroker.removeSession(ConnectionContext context, SessionInfo info)
           
 void BrokerFilter.removeSession(ConnectionContext context, SessionInfo info)
           
 void BrokerBroadcaster.removeSession(ConnectionContext context, SessionInfo info)
           
 void Broker.removeSession(ConnectionContext context, SessionInfo info)
          Removes a session.
 void MutableBrokerFilter.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void ErrorBroker.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void EmptyBroker.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void BrokerFilter.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void BrokerBroadcaster.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void TransactionBroker.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void MutableBrokerFilter.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void ErrorBroker.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void EmptyBroker.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void BrokerFilter.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void BrokerBroadcaster.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void Broker.rollbackTransaction(ConnectionContext context, TransactionId xid)
          Rollsback a transaction.
 void MutableBrokerFilter.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void ErrorBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void EmptyBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void BrokerFilter.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void Broker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
          A message needs to go the a DLQ
 void MutableBrokerFilter.setAdminConnectionContext(ConnectionContext adminConnectionContext)
           
 void ErrorBroker.setAdminConnectionContext(ConnectionContext adminConnectionContext)
           
 void EmptyBroker.setAdminConnectionContext(ConnectionContext adminConnectionContext)
           
 void BrokerFilter.setAdminConnectionContext(ConnectionContext adminConnectionContext)
           
 void Broker.setAdminConnectionContext(ConnectionContext adminConnectionContext)
          Sets the default administration connection context used when configuring the broker on startup or via JMX
 void ProducerBrokerExchange.setConnectionContext(ConnectionContext connectionContext)
           
 void ConsumerBrokerExchange.setConnectionContext(ConnectionContext connectionContext)
           
 void TransportConnectionState.setContext(ConnectionContext context)
           
 void MutableBrokerFilter.slowConsumer(ConnectionContext context, Destination dest, Subscription subs)
           
 void ErrorBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void EmptyBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void BrokerFilter.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void Broker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
          Called when there is a slow consumer
 

Uses of ConnectionContext in org.apache.activemq.broker.cluster
 

Methods in org.apache.activemq.broker.cluster with parameters of type ConnectionContext
 Subscription ConnectionSplitBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ConnectionSplitBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.ft
 

Methods in org.apache.activemq.broker.ft with parameters of type ConnectionContext
 void MasterBroker.addConnection(ConnectionContext context, ConnectionInfo info)
          A client is establishing a connection with the broker.
 Subscription MasterBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
          add a consumer
 void MasterBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void MasterBroker.addProducer(ConnectionContext context, ProducerInfo info)
          Adds a producer.
 void MasterBroker.addSession(ConnectionContext context, SessionInfo info)
          Adds a session.
 void MasterBroker.beginTransaction(ConnectionContext context, TransactionId xid)
          begin a transaction
 void MasterBroker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
          Commits a transaction.
 void MasterBroker.forgetTransaction(ConnectionContext context, TransactionId xid)
          Forgets a transaction.
 int MasterBroker.prepareTransaction(ConnectionContext context, TransactionId xid)
          Prepares a transaction.
 void MasterBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
          A client is disconnecting from the broker.
 void MasterBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void MasterBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void MasterBroker.removeProducer(ConnectionContext context, ProducerInfo info)
          Removes a producer.
 void MasterBroker.removeSession(ConnectionContext context, SessionInfo info)
          Removes a session.
 void MasterBroker.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
          remove a subscription
 void MasterBroker.rollbackTransaction(ConnectionContext context, TransactionId xid)
          Rollsback a transaction.
 

Uses of ConnectionContext in org.apache.activemq.broker.jmx
 

Methods in org.apache.activemq.broker.jmx with parameters of type ConnectionContext
 Subscription ManagedRegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ManagedRegionBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
protected  Destination ManagedTopicRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination ManagedTempTopicRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination ManagedTempQueueRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination ManagedQueueRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Subscription ManagedTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
 ObjectName ManagedRegionBroker.registerSubscription(ConnectionContext context, Subscription sub)
           
 void ManagedRegionBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ManagedTopicRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ManagedTempTopicRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ManagedTempQueueRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ManagedQueueRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ManagedRegionBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.region
 

Fields in org.apache.activemq.broker.region declared as ConnectionContext
protected  ConnectionContext AbstractSubscription.context
           
 

Methods in org.apache.activemq.broker.region that return ConnectionContext
protected  ConnectionContext BaseDestination.createConnectionContext()
           
 ConnectionContext RegionBroker.getAdminConnectionContext()
           
 ConnectionContext Subscription.getContext()
           
 ConnectionContext AbstractSubscription.getContext()
           
 

Methods in org.apache.activemq.broker.region with parameters of type ConnectionContext
 void TopicSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
 void Subscription.acknowledge(ConnectionContext context, MessageAck ack)
          Used when client acknowledge receipt of dispatched message.
 void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
protected  void QueueSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference n)
          In the queue case, mark the node as dropped and then a gc cycle will remove it from the queue.
protected  void QueueBrowserSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference n)
          Since we are a browser we don't really remove the message from the queue.
protected abstract  void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
          Used during acknowledgment to remove the message.
protected  void DurableTopicSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
           
 void Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Queue.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Topic.activate(ConnectionContext context, DurableTopicSubscription subscription)
           
 void DurableTopicSubscription.activate(SystemUsage memoryManager, ConnectionContext context, ConsumerInfo info, RegionBroker regionBroker)
           
 void Subscription.add(ConnectionContext context, Destination destination)
          The subscription will be receiving messages from the destination.
 void PrefetchSubscription.add(ConnectionContext context, Destination destination)
           
 void DurableTopicSubscription.add(ConnectionContext context, Destination destination)
           
 void AbstractSubscription.add(ConnectionContext context, Destination destination)
           
 void RegionBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 Subscription TopicRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription RegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription Region.addConsumer(ConnectionContext context, ConsumerInfo info)
          Adds a consumer.
 Subscription AbstractRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination RegionBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemp)
           
 Destination Region.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
          Used to create a destination.
 Destination AbstractRegion.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
           
 void RegionBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void RegionBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 void Region.addProducer(ConnectionContext context, ProducerInfo info)
          Adds a Producer.
 void DestinationFilter.addProducer(ConnectionContext context, ProducerInfo info)
           
 void Destination.addProducer(ConnectionContext context, ProducerInfo info)
           
 void BaseDestination.addProducer(ConnectionContext context, ProducerInfo info)
           
 void AbstractRegion.addProducer(ConnectionContext context, ProducerInfo info)
           
 boolean SubscriptionRecovery.addRecoveredMessage(ConnectionContext context, MessageReference message)
          Add a message to the SubscriptionRecovery
 boolean AbstractSubscription.addRecoveredMessage(ConnectionContext context, MessageReference message)
           
 void Topic.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempTopic.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempQueue.addSubscription(ConnectionContext context, Subscription sub)
           
 void Queue.addSubscription(ConnectionContext context, Subscription sub)
           
 void DestinationFilter.addSubscription(ConnectionContext context, Subscription sub)
           
 void Destination.addSubscription(ConnectionContext context, Subscription sub)
           
 void BaseDestination.addSubscription(ConnectionContext context, Subscription sub)
           
protected  List<Subscription> TopicRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
           
protected  List<Subscription> AbstractRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
           
 void RegionBroker.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void RegionBroker.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 int Queue.copyMatchingMessages(ConnectionContext context, MessageReferenceFilter filter, ActiveMQDestination dest, int maximumMessages)
          Copies the messages matching the given filter up to the maximum number of matched messages
 int Queue.copyMatchingMessagesTo(ConnectionContext context, String selector, ActiveMQDestination dest)
          Copies the messages matching the given selector
 int Queue.copyMatchingMessagesTo(ConnectionContext context, String selector, ActiveMQDestination dest, int maximumMessages)
          Copies the messages matching the given selector up to the maximum number of matched messages
 boolean Queue.copyMessageTo(ConnectionContext context, String messageId, ActiveMQDestination dest)
          Copies the message matching the given messageId
 void DestinationInterceptor.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void CompositeDestinationInterceptor.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination AbstractTempRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination AbstractRegion.createDestination(ConnectionContext context, ActiveMQDestination destination)
           
 Destination DestinationFactoryImpl.createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
           
abstract  Destination DestinationFactory.createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
          Create destination implementation.
protected  Subscription TopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription QueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected abstract  Subscription AbstractRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
 void Topic.deactivate(ConnectionContext context, DurableTopicSubscription sub)
           
 void Topic.deleteSubscription(ConnectionContext context, SubscriptionKey key)
           
protected  void Topic.dispatch(ConnectionContext context, Message message)
           
 void TempQueue.dispose(ConnectionContext context)
           
 void DestinationFilter.dispose(ConnectionContext context)
           
 void Destination.dispose(ConnectionContext context)
           
 void BaseDestination.dispose(ConnectionContext context)
           
protected  void AbstractTempRegion.dispose(ConnectionContext context, Destination dest)
           
protected  void AbstractRegion.dispose(ConnectionContext context, Destination dest)
           
protected  Destination TempTopicRegion.doCreateDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected  Destination TempQueueRegion.doCreateDestination(ConnectionContext context, ActiveMQDestination destination)
           
protected abstract  Destination AbstractTempRegion.doCreateDestination(ConnectionContext context, ActiveMQDestination destination)
           
 boolean MessageReferenceFilter.evaluate(ConnectionContext context, MessageReference messageReference)
           
 void DestinationFilter.fastProducer(ConnectionContext context, ProducerInfo producerInfo)
           
 void Destination.fastProducer(ConnectionContext context, ProducerInfo producerInfo)
          Called to notify a producer is too fast
 void BaseDestination.fastProducer(ConnectionContext context, ProducerInfo producerInfo)
          Called to notify a producer is too fast
 void RegionBroker.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 TransactionId[] RegionBroker.getPreparedTransactions(ConnectionContext context)
           
 void DestinationFilter.isFull(ConnectionContext context, Usage<?> usage)
           
 void Destination.isFull(ConnectionContext context, Usage<?> usage)
          Called when a Usage reaches a limit
 void BaseDestination.isFull(ConnectionContext context, Usage<?> usage)
          Called when a Usage reaches a limit
protected  Destination AbstractRegion.lookup(ConnectionContext context, ActiveMQDestination destination, boolean createTemporary)
           
 void DestinationFilter.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void Destination.messageConsumed(ConnectionContext context, MessageReference messageReference)
          called when message is consumed
 void BaseDestination.messageConsumed(ConnectionContext context, MessageReference messageReference)
          called when message is consumed
 void DestinationFilter.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void Destination.messageDelivered(ConnectionContext context, MessageReference messageReference)
          Called when message is delivered to the broker
 void BaseDestination.messageDelivered(ConnectionContext context, MessageReference messageReference)
          Called when message is delivered to the broker
 void DestinationFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void Destination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void BaseDestination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void Queue.messageExpired(ConnectionContext context, MessageReference reference)
           
 void RegionBroker.messageExpired(ConnectionContext context, MessageReference node, Subscription subscription)
           
 void DestinationFilter.messageExpired(ConnectionContext context, PrefetchSubscription prefetchSubscription, MessageReference node)
           
 void Topic.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
 void Queue.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
 void DestinationFilter.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
           
 void Destination.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
          Inform the Destination a message has expired
 Response RegionBroker.messagePull(ConnectionContext context, MessagePull pull)
           
 Response Region.messagePull(ConnectionContext context, MessagePull pull)
          Allows a consumer to pull a message from a queue
 Response AbstractRegion.messagePull(ConnectionContext context, MessagePull pull)
           
 int Queue.moveMatchingMessagesTo(ConnectionContext context, MessageReferenceFilter filter, ActiveMQDestination dest, int maximumMessages)
          Moves the messages matching the given filter up to the maximum number of matched messages
 int Queue.moveMatchingMessagesTo(ConnectionContext context, String selector, ActiveMQDestination dest)
          Moves the messages matching the given selector
 int Queue.moveMatchingMessagesTo(ConnectionContext context, String selector, ActiveMQDestination dest, int maximumMessages)
          Moves the messages matching the given selector up to the maximum number of matched messages
 boolean Queue.moveMessageTo(ConnectionContext context, QueueMessageReference m, ActiveMQDestination dest)
          Move a message
 boolean Queue.moveMessageTo(ConnectionContext context, String messageId, ActiveMQDestination dest)
          Moves the message matching the given messageId
protected  void BaseDestination.onMessageWithNoConsumers(ConnectionContext context, Message msg)
          Provides a hook to allow messages with no consumer to be processed in some way - such as to send to a dead letter queue or something..
 int RegionBroker.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 Response TopicSubscription.pullMessage(ConnectionContext context, MessagePull pull)
           
 Response Subscription.pullMessage(ConnectionContext context, MessagePull pull)
          Allows a consumer to pull a message on demand
 Response PrefetchSubscription.pullMessage(ConnectionContext context, MessagePull pull)
          Allows a message to be pulled on demand by a client
protected  void Topic.recoverRetroactiveMessages(ConnectionContext context, Subscription subscription)
           
 List<MessageReference> Subscription.remove(ConnectionContext context, Destination destination)
          The subscription will be no longer be receiving messages from the destination.
 List<MessageReference> QueueBrowserSubscription.remove(ConnectionContext context, Destination destination)
           
 List<MessageReference> PrefetchSubscription.remove(ConnectionContext context, Destination destination)
           
 List<MessageReference> AbstractSubscription.remove(ConnectionContext context, Destination destination)
           
 void RegionBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void TopicRegion.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void RegionBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void Region.removeConsumer(ConnectionContext context, ConsumerInfo info)
          Removes a consumer.
 void AbstractRegion.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void TempTopicRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void TempQueueRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void RegionBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void Region.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
          Used to destroy a destination.
 void AbstractRegion.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void RegionBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
protected  void Queue.removeMessage(ConnectionContext c, QueueMessageReference r)
           
protected  void Queue.removeMessage(ConnectionContext c, Subscription subs, QueueMessageReference r)
           
protected  void Queue.removeMessage(ConnectionContext context, Subscription sub, QueueMessageReference reference, MessageAck ack)
           
 void RegionBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void Region.removeProducer(ConnectionContext context, ProducerInfo info)
          Removes a Producer.
 void DestinationFilter.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void Destination.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void BaseDestination.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void AbstractRegion.removeProducer(ConnectionContext context, ProducerInfo info)
          Removes a Producer.
 void TopicRegion.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void RegionBroker.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void Region.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
          Deletes a durable subscription.
 void AbstractRegion.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void Topic.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Queue.removeSubscription(ConnectionContext context, Subscription sub, long lastDeiveredSequenceId)
           
 void DestinationFilter.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Destination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void BaseDestination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void RegionBroker.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void RegionBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference node, Subscription subscription)
           
protected  void PrefetchSubscription.sendToDLQ(ConnectionContext context, MessageReference node)
           
 void RegionBroker.setAdminConnectionContext(ConnectionContext adminConnectionContext)
           
 void DestinationFilter.slowConsumer(ConnectionContext context, Subscription subs)
           
 void Destination.slowConsumer(ConnectionContext context, Subscription subs)
          Called when there is a slow consumer
 void BaseDestination.slowConsumer(ConnectionContext context, Subscription subs)
          Called when there is a slow consumer
protected  void BaseDestination.waitForSpace(ConnectionContext context, Usage<?> usage, int highWaterMark, String warning)
           
protected  void BaseDestination.waitForSpace(ConnectionContext context, Usage<?> usage, String warning)
           
 

Constructors in org.apache.activemq.broker.region with parameters of type ConnectionContext
AbstractSubscription(Broker broker, ConnectionContext context, ConsumerInfo info)
           
DurableTopicSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, boolean keepDurableSubsActive)
           
PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor)
           
QueueBrowserSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
QueueSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
TopicSubscription(Broker broker, ConnectionContext context, ConsumerInfo info, SystemUsage usageManager)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.region.cursors
 

Methods in org.apache.activemq.broker.region.cursors with parameters of type ConnectionContext
 void StoreDurableSubscriberCursor.add(ConnectionContext context, Destination destination)
          Add a destination
 void PendingMessageCursor.add(ConnectionContext context, Destination destination)
          Add a destination
 void AbstractPendingMessageCursor.add(ConnectionContext context, Destination destination)
           
 List<MessageReference> VMPendingMessageCursor.remove(ConnectionContext context, Destination destination)
           
 List<MessageReference> StoreDurableSubscriberCursor.remove(ConnectionContext context, Destination destination)
          remove a destination
 List<MessageReference> PendingMessageCursor.remove(ConnectionContext context, Destination destination)
          remove a destination
 List<MessageReference> AbstractPendingMessageCursor.remove(ConnectionContext context, Destination destination)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.region.policy
 

Methods in org.apache.activemq.broker.region.policy with parameters of type ConnectionContext
 boolean TimedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean SubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
          A message was sent to the destination.
 boolean QueryBasedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean NoSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
 boolean LastImageSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
 boolean FixedSizedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean FixedCountSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
protected  void QueryBasedSubscriptionRecoveryPolicy.dispatchInitialMessage(Message message, Destination regionDestination, ConnectionContext context, SubscriptionRecovery sub)
           
 void TimedSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void SubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
          Let a subscription recover message held by the policy.
 void QueryBasedSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void NoSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void LastImageSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void FixedSizedSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void FixedCountSubscriptionRecoveryPolicy.recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
           
 void SlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
           
 void AbortSlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.region.virtual
 

Methods in org.apache.activemq.broker.region.virtual with parameters of type ConnectionContext
 void VirtualTopic.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void VirtualDestinationInterceptor.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void MirroredQueue.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void CompositeDestination.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.scheduler
 

Methods in org.apache.activemq.broker.scheduler with parameters of type ConnectionContext
protected  void SchedulerBroker.sendScheduledJob(ConnectionContext context, Job job, ActiveMQDestination replyTo)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.util
 

Methods in org.apache.activemq.broker.util with parameters of type ConnectionContext
 void UDPTraceBrokerPlugin.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void LoggingBrokerPlugin.addConnection(ConnectionContext context, ConnectionInfo info)
           
 Subscription UDPTraceBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription LoggingBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription DestinationPathSeparatorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination LoggingBrokerPlugin.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
           
 Destination DestinationPathSeparatorBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)
           
 void UDPTraceBrokerPlugin.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void LoggingBrokerPlugin.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void DestinationPathSeparatorBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void UDPTraceBrokerPlugin.addProducer(ConnectionContext context, ProducerInfo info)
           
 void LoggingBrokerPlugin.addProducer(ConnectionContext context, ProducerInfo info)
           
 void DestinationPathSeparatorBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 void UDPTraceBrokerPlugin.addSession(ConnectionContext context, SessionInfo info)
           
 void LoggingBrokerPlugin.addSession(ConnectionContext context, SessionInfo info)
           
 void UDPTraceBrokerPlugin.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void LoggingBrokerPlugin.beginTransaction(ConnectionContext context, TransactionId xid)
           
 void UDPTraceBrokerPlugin.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void LoggingBrokerPlugin.commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase)
           
 void LoggingBrokerPlugin.fastProducer(ConnectionContext context, ProducerInfo producerInfo, ActiveMQDestination destination)
           
 void UDPTraceBrokerPlugin.forgetTransaction(ConnectionContext context, TransactionId xid)
           
 void LoggingBrokerPlugin.forgetTransaction(ConnectionContext context, TransactionId transactionId)
           
 TransactionId[] LoggingBrokerPlugin.getPreparedTransactions(ConnectionContext context)
           
 void LoggingBrokerPlugin.isFull(ConnectionContext context, Destination destination, Usage usage)
           
 void LoggingBrokerPlugin.messageConsumed(ConnectionContext context, MessageReference messageReference)
           
 void LoggingBrokerPlugin.messageDelivered(ConnectionContext context, MessageReference messageReference)
           
 void LoggingBrokerPlugin.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void LoggingBrokerPlugin.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 Response UDPTraceBrokerPlugin.messagePull(ConnectionContext context, MessagePull pull)
           
 Response LoggingBrokerPlugin.messagePull(ConnectionContext context, MessagePull pull)
           
 Response DestinationPathSeparatorBroker.messagePull(ConnectionContext context, MessagePull pull)
           
 int UDPTraceBrokerPlugin.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 int LoggingBrokerPlugin.prepareTransaction(ConnectionContext context, TransactionId xid)
           
 void UDPTraceBrokerPlugin.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void LoggingBrokerPlugin.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void UDPTraceBrokerPlugin.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void LoggingBrokerPlugin.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void DestinationPathSeparatorBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void UDPTraceBrokerPlugin.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void LoggingBrokerPlugin.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void DestinationPathSeparatorBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void UDPTraceBrokerPlugin.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void LoggingBrokerPlugin.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void DestinationPathSeparatorBroker.removeDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void UDPTraceBrokerPlugin.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void LoggingBrokerPlugin.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void DestinationPathSeparatorBroker.removeProducer(ConnectionContext context, ProducerInfo info)
           
 void UDPTraceBrokerPlugin.removeSession(ConnectionContext context, SessionInfo info)
           
 void LoggingBrokerPlugin.removeSession(ConnectionContext context, SessionInfo info)
           
 void UDPTraceBrokerPlugin.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void LoggingBrokerPlugin.removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info)
           
 void UDPTraceBrokerPlugin.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void LoggingBrokerPlugin.rollbackTransaction(ConnectionContext context, TransactionId xid)
           
 void RedeliveryPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void LoggingBrokerPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void LoggingBrokerPlugin.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 

Uses of ConnectionContext in org.apache.activemq.broker.view
 

Methods in org.apache.activemq.broker.view with parameters of type ConnectionContext
 Subscription ConnectionDotFileInterceptor.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination DestinationDotFileInterceptor.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
           
 void ConnectionDotFileInterceptor.addProducer(ConnectionContext context, ProducerInfo info)
           
 void ConnectionDotFileInterceptor.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void DestinationDotFileInterceptor.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 void ConnectionDotFileInterceptor.removeProducer(ConnectionContext context, ProducerInfo info)
           
 

Uses of ConnectionContext in org.apache.activemq.plugin
 

Methods in org.apache.activemq.plugin with parameters of type ConnectionContext
 Subscription SubQueueSelectorCacheBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
protected  void StatisticsBroker.sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo)
           
protected  void StatisticsBroker.sendSubStats(ConnectionContext context, ObjectName[] subscribers, ActiveMQDestination replyTo)
           
 void DiscardingDLQBroker.sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription)
           
 

Uses of ConnectionContext in org.apache.activemq.security
 

Methods in org.apache.activemq.security with parameters of type ConnectionContext
 void SimpleAuthenticationBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 void JaasDualAuthenticationBroker.addConnection(ConnectionContext context, ConnectionInfo info)
          Overridden to allow for authentication using different Jaas configurations depending on if the connection is SSL or not.
 void JaasCertificateAuthenticationBroker.addConnection(ConnectionContext context, ConnectionInfo info)
          Overridden to allow for authentication based on client certificates.
 void JaasAuthenticationBroker.addConnection(ConnectionContext context, ConnectionInfo info)
           
 Subscription AuthorizationBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Destination AuthorizationBroker.addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create)
           
 void AuthorizationBroker.addDestinationInfo(ConnectionContext context, DestinationInfo info)
           
 void AuthorizationBroker.addProducer(ConnectionContext context, ProducerInfo info)
           
 boolean MessageAuthorizationPolicy.isAllowedToConsume(ConnectionContext context, Message message)
          Returns true if the given message is able to be dispatched to the connection performing any user
 void SimpleAuthenticationBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void JaasDualAuthenticationBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
          Overriding removeConnection to make sure the security context is cleaned.
 void JaasCertificateAuthenticationBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
          Overriding removeConnection to make sure the security context is cleaned.
 void JaasAuthenticationBroker.removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error)
           
 void AuthorizationBroker.removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
           
 

Uses of ConnectionContext in org.apache.activemq.store
 

Methods in org.apache.activemq.store with parameters of type ConnectionContext
 void TopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
          Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint
 void ProxyTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 boolean TopicReferenceStore.acknowledgeReference(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
          Removes the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint N.B.
 void ProxyTopicMessageStore.addMessage(ConnectionContext context, Message message)
           
 void ProxyMessageStore.addMessage(ConnectionContext context, Message message)
           
 void MessageStore.addMessage(ConnectionContext context, Message message)
          Adds a message to the message store
 void ProxyTopicMessageStore.addMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 void ProxyMessageStore.addMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 void MessageStore.addMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
          Adds a message to the message store
 void AbstractMessageStore.addMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 boolean ReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)
          Adds a message reference to the message store
 Future<Object> ProxyTopicMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message)
           
 Future<Object> ProxyMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message)
           
 Future<Object> MessageStore.asyncAddQueueMessage(ConnectionContext context, Message message)
          Adds a message to the message store
 Future<Object> AbstractMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message)
           
 Future<Object> ProxyTopicMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 Future<Object> ProxyMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 Future<Object> MessageStore.asyncAddQueueMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
          Adds a message to the message store
 Future<Object> AbstractMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 Future<Object> ProxyTopicMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message)
           
 Future<Object> ProxyMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message)
           
 Future<Object> MessageStore.asyncAddTopicMessage(ConnectionContext context, Message message)
          Adds a message to the message store
 Future<Object> AbstractMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message)
           
 Future<Object> ProxyTopicMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 Future<Object> ProxyMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 Future<Object> MessageStore.asyncAddTopicMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
          Adds a message to the message store
 Future<Object> AbstractMessageStore.asyncAddTopicMessage(ConnectionContext context, Message message, boolean canOptimizeHint)
           
 void PersistenceAdapter.beginTransaction(ConnectionContext context)
          This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimization.
 void PersistenceAdapter.commitTransaction(ConnectionContext context)
          Commit a persistence transaction
 void ProxyTopicMessageStore.dispose(ConnectionContext context)
           
 void ProxyMessageStore.dispose(ConnectionContext context)
           
 void MessageStore.dispose(ConnectionContext context)
           
 void AbstractMessageStore.dispose(ConnectionContext context)
           
 void ProxyTopicMessageStore.removeAllMessages(ConnectionContext context)
           
 void ProxyMessageStore.removeAllMessages(ConnectionContext context)
           
 void MessageStore.removeAllMessages(ConnectionContext context)
          Removes all the messages from the message store.
 void ProxyTopicMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void MessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void AbstractMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyTopicMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void MessageStore.removeMessage(ConnectionContext context, MessageAck ack)
          Removes a message from the message store.
 void PersistenceAdapter.rollbackTransaction(ConnectionContext context)
          Rollback a persistence transaction
 

Uses of ConnectionContext in org.apache.activemq.store.amq
 

Methods in org.apache.activemq.store.amq with parameters of type ConnectionContext
protected  void AMQTopicMessageStore.acknowledge(ConnectionContext context, MessageId messageId, Location location, String clientId, String subscriptionName)
           
 void AMQTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck originalAck)
           
 void AMQMessageStore.addMessage(ConnectionContext context, Message message)
          Not synchronize since the Journal has better throughput if you increase the number of concurrent writes that it is doing.
 void AMQMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
           
 void AMQPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void AMQPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void AMQMessageStore.dispose(ConnectionContext context)
           
 void AMQMessageStore.removeAllMessages(ConnectionContext context)
           
 void AMQMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 boolean AMQTxOperation.replay(AMQPersistenceAdapter adapter, ConnectionContext context)
           
 boolean AMQTopicMessageStore.replayAcknowledge(ConnectionContext context, String clientId, String subscritionName, MessageId messageId)
           
 boolean AMQMessageStore.replayAddMessage(ConnectionContext context, Message message, Location location)
           
 boolean AMQMessageStore.replayRemoveMessage(ConnectionContext context, MessageAck messageAck)
           
 void AMQPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.store.jdbc
 

Methods in org.apache.activemq.store.jdbc with parameters of type ConnectionContext
 void JDBCTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void JDBCMessageStore.addMessage(ConnectionContext context, Message message)
           
 void JDBCMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
           
 void JDBCPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void JDBCPersistenceAdapter.commitAdd(ConnectionContext context, MessageId messageId)
           
 void JDBCPersistenceAdapter.commitLastAck(ConnectionContext context, long xidLastAck, long priority, ActiveMQDestination destination, String subName, String clientId)
           
 void JDBCPersistenceAdapter.commitRemove(ConnectionContext context, MessageAck ack)
           
 void JDBCPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 TransactionContext JDBCPersistenceAdapter.getTransactionContext(ConnectionContext context)
           
 void JDBCMessageStore.removeAllMessages(ConnectionContext context)
           
 void JDBCMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void JDBCPersistenceAdapter.rollbackLastAck(ConnectionContext context, byte priority, ActiveMQDestination destination, String subName, String clientId)
           
 void JDBCPersistenceAdapter.rollbackLastAck(ConnectionContext context, JDBCTopicMessageStore store, MessageAck ack, String subName, String clientId)
           
 void JDBCPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.store.journal
 

Methods in org.apache.activemq.store.journal with parameters of type ConnectionContext
 void JournalTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck originalAck)
           
 void JournalTopicMessageStore.addMessage(ConnectionContext context, Message message)
           
 void JournalMessageStore.addMessage(ConnectionContext context, Message message)
          Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing.
 void JournalMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
           
 void JournalPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void JournalPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void JournalMessageStore.removeAllMessages(ConnectionContext context)
           
 void JournalMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void JournalTopicMessageStore.replayAcknowledge(ConnectionContext context, String clientId, String subscritionName, MessageId messageId)
           
 void JournalMessageStore.replayAddMessage(ConnectionContext context, Message message)
           
 void JournalMessageStore.replayRemoveMessage(ConnectionContext context, MessageAck messageAck)
           
 void JournalPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.store.kahadaptor
 

Methods in org.apache.activemq.store.kahadaptor with parameters of type ConnectionContext
 void KahaTopicReferenceStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void KahaTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 boolean KahaTopicReferenceStore.acknowledgeReference(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 void KahaTopicReferenceStore.addMessage(ConnectionContext context, Message message)
           
 void KahaTopicMessageStore.addMessage(ConnectionContext context, Message message)
           
 void KahaReferenceStore.addMessage(ConnectionContext context, Message message)
           
 void KahaMessageStore.addMessage(ConnectionContext context, Message message)
           
 boolean KahaTopicReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)
           
 boolean KahaReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)
           
 void KahaPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void KahaReferenceStoreAdapter.commitTransaction(ConnectionContext context)
           
 void KahaPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void KahaTopicReferenceStore.dispose(ConnectionContext context)
           
 void KahaReferenceStore.dispose(ConnectionContext context)
           
 void KahaTopicReferenceStore.removeAllMessages(ConnectionContext context)
           
 void KahaTopicMessageStore.removeAllMessages(ConnectionContext context)
           
 void KahaReferenceStore.removeAllMessages(ConnectionContext context)
           
 void KahaMessageStore.removeAllMessages(ConnectionContext context)
           
 void KahaReferenceStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void KahaMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void KahaPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.store.kahadb
 

Methods in org.apache.activemq.store.kahadb with parameters of type ConnectionContext
 void TempKahaDBStore.KahaDBMessageStore.addMessage(ConnectionContext context, Message message)
           
 void KahaDBStore.KahaDBMessageStore.addMessage(ConnectionContext context, Message message)
           
 Future<Object> KahaDBStore.KahaDBMessageStore.asyncAddQueueMessage(ConnectionContext context, Message message)
           
 void TempKahaDBStore.beginTransaction(ConnectionContext context)
           
 void MultiKahaDBPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void KahaDBStore.beginTransaction(ConnectionContext context)
           
 void KahaDBPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void TempKahaDBStore.commitTransaction(ConnectionContext context)
           
 void MultiKahaDBPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void KahaDBStore.commitTransaction(ConnectionContext context)
           
 void KahaDBPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void TempKahaDBStore.KahaDBMessageStore.removeAllMessages(ConnectionContext context)
           
 void KahaDBStore.KahaDBMessageStore.removeAllMessages(ConnectionContext context)
           
 void KahaDBStore.KahaDBMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void TempKahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void KahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void TempKahaDBStore.rollbackTransaction(ConnectionContext context)
           
 void MultiKahaDBPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 void KahaDBStore.rollbackTransaction(ConnectionContext context)
           
 void KahaDBPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.store.memory
 

Methods in org.apache.activemq.store.memory with parameters of type ConnectionContext
 void MemoryTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void MemoryTopicMessageStore.addMessage(ConnectionContext context, Message message)
           
 void MemoryMessageStore.addMessage(ConnectionContext context, Message message)
           
 void MemoryPersistenceAdapter.beginTransaction(ConnectionContext context)
           
 void MemoryPersistenceAdapter.commitTransaction(ConnectionContext context)
           
 void MemoryMessageStore.removeAllMessages(ConnectionContext context)
           
 void MemoryMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void MemoryPersistenceAdapter.rollbackTransaction(ConnectionContext context)
           
 void MemoryTransactionStore.AddMessageCommand.run(ConnectionContext context)
           
 void MemoryTransactionStore.RemoveMessageCommand.run(ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.transaction
 

Constructors in org.apache.activemq.transaction with parameters of type ConnectionContext
LocalTransaction(TransactionStore transactionStore, LocalTransactionId xid, ConnectionContext context)
           
 

Uses of ConnectionContext in org.apache.activemq.util
 

Methods in org.apache.activemq.util that return ConnectionContext
protected static ConnectionContext BrokerSupport.createAdminConnectionContext(Broker broker)
          Factory method to create the new administration connection context object.
static ConnectionContext BrokerSupport.getConnectionContext(Broker broker)
          Returns the broker's administration connection context used for configuring the broker at startup
 ConnectionContext TransactionTemplate.getContext()
           
 

Methods in org.apache.activemq.util with parameters of type ConnectionContext
static void BrokerSupport.doResend(ConnectionContext context, Message originalMessage, ActiveMQDestination deadLetterDestination, boolean copy)
           
static void BrokerSupport.resend(ConnectionContext context, Message originalMessage, ActiveMQDestination deadLetterDestination)
           
static void BrokerSupport.resendNoCopy(ConnectionContext context, Message originalMessage, ActiveMQDestination deadLetterDestination)
           
 

Constructors in org.apache.activemq.util with parameters of type ConnectionContext
TransactionTemplate(PersistenceAdapter persistenceAdapter, ConnectionContext context)
           
 



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