Uses of Interface
org.codehaus.activemq.broker.BrokerClient

Packages that use BrokerClient
org.codehaus.activemq.broker The API for the JMS Broker which is the server side of a JMS network though it may be deployed inside a client in peer style networks. 
org.codehaus.activemq.broker.impl The default implementation of the JMS Broker  
org.codehaus.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager  
org.codehaus.activemq.service.boundedvm   
org.codehaus.activemq.service.impl Default implementations of the services  
 

Uses of BrokerClient in org.codehaus.activemq.broker
 

Methods in org.codehaus.activemq.broker with parameters of type BrokerClient
 void BrokerContainer.registerConnection(BrokerClient client, ConnectionInfo info)
          registers a new Connection
 void BrokerContainer.deregisterConnection(BrokerClient client, ConnectionInfo info)
          un-registers a Connection
 void BrokerContainer.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerContainer.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerContainer.registerMessageProducer(BrokerClient client, ProducerInfo info)
          Registers a MessageProducer
 void BrokerContainer.deregisterMessageProducer(BrokerClient client, ProducerInfo info)
          De-register a MessageProducer from the Broker
 void BrokerContainer.registerSession(BrokerClient client, SessionInfo info)
          Register a client-side Session (used for Monitoring)
 void BrokerContainer.deregisterSession(BrokerClient client, SessionInfo info)
          De-register a client-side Session from the Broker (used for monitoring)
 void BrokerContainer.startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction from the Client session
 void BrokerContainer.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          Rollback a transacton
 void BrokerContainer.commitTransaction(BrokerClient client, java.lang.String transactionId)
          Commit a transaction
 void BrokerContainer.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerContainer.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge receipt of a message within a transaction context
 void BrokerContainer.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerContainer.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge reciept of a message
 void BrokerContainer.durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds)
          Command to delete a durable topic subscription
 void BrokerContainer.startTransaction(BrokerClient client, ActiveMQXid xid)
          Start an XA transaction.
 ActiveMQXid[] BrokerContainer.getPreparedTransactions(BrokerClient client)
          Gets the prepared XA transactions.
 int BrokerContainer.prepareTransaction(BrokerClient client, ActiveMQXid xid)
          Prepare an XA transaction.
 void BrokerContainer.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
          Rollback an XA transaction.
 void BrokerContainer.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
          Commit an XA transaction.
 void BrokerConnector.registerClient(BrokerClient client, ConnectionInfo info)
          Register a Broker Client
 void BrokerConnector.deregisterClient(BrokerClient client, ConnectionInfo info)
          Deregister a Broker Client
 void BrokerConnector.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerConnector.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerConnector.registerMessageProducer(BrokerClient client, ProducerInfo info)
          Registers a MessageProducer
 void BrokerConnector.deregisterMessageProducer(BrokerClient client, ProducerInfo info)
          De-register a MessageProducer from the Broker
 void BrokerConnector.registerSession(BrokerClient client, SessionInfo info)
          Register a client-side Session (used for Monitoring)
 void BrokerConnector.deregisterSession(BrokerClient client, SessionInfo info)
          De-register a client-side Session from the Broker (used for monitoring)
 void BrokerConnector.startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction from the Client session
 void BrokerConnector.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          Rollback a transacton
 void BrokerConnector.commitTransaction(BrokerClient client, java.lang.String transactionId)
          Commit a transaction
 void BrokerConnector.startTransaction(BrokerClient client, ActiveMQXid xid)
          Start an XA transaction
 ActiveMQXid[] BrokerConnector.getPreparedTransactions(BrokerClient client)
          Get all the Xids of the prepared XA transactions.
 int BrokerConnector.prepareTransaction(BrokerClient client, ActiveMQXid xid)
          Prepare an XA transaction.
 void BrokerConnector.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
          Rollback an XA transaction.
 void BrokerConnector.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
          Commit an XA transaction.
 void BrokerConnector.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerConnector.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge receipt of a message within a transaction context
 void BrokerConnector.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerConnector.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge reciept of a message
 void BrokerConnector.durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds)
          Command to delete a durable topic subscription
 java.lang.String BrokerConnector.getResourceManagerId(BrokerClient client)
          Gets the unique id of the resource manager used for managing xa transactions.
 void Broker.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add an active message consumer
 void Broker.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
          remove an active message consumer
 ActiveMQXid[] Broker.getPreparedTransactions(BrokerClient client)
          gets a list of all the prepared xa transactions.
 void Broker.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge consumption of a message by the Message Consumer
 void Broker.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge consumption of a message within a transaction
 void Broker.redeliverMessage(BrokerClient client, MessageAck ack)
          Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue
 void Broker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void Broker.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send a message to the broker within a transaction
 void Broker.cleanUpClient(BrokerClient client)
          A hint to the broker that an BrokerClient has stopped This enables the broker to clean-up any outstanding processing that may be outstanding
 void Broker.startTransaction(BrokerClient client, java.lang.String transactionId)
          start a transaction
 void Broker.commitTransaction(BrokerClient client, java.lang.String transactionId)
          commit a transaction
 void Broker.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          rollback a transaction
 void Broker.startTransaction(BrokerClient client, ActiveMQXid xid)
           
 int Broker.prepareTransaction(BrokerClient client, ActiveMQXid xid)
           
 void Broker.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
           
 void Broker.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
           
 

Uses of BrokerClient in org.codehaus.activemq.broker.impl
 

Classes in org.codehaus.activemq.broker.impl that implement BrokerClient
 class BrokerClientImpl
          A Broker client side proxy representing a JMS Connnection
 

Methods in org.codehaus.activemq.broker.impl with parameters of type BrokerClient
 void DefaultBroker.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge consumption of a message by the Message Consumer
 void DefaultBroker.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge consumption of a message within a transaction
 void DefaultBroker.sendMessage(BrokerClient client, ActiveMQMessage message)
          send a message to the broker
 void DefaultBroker.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send a message to the broker within a transaction
 void DefaultBroker.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add an active message consumer
 void DefaultBroker.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
          remove an active message consumer
 void DefaultBroker.redeliverMessage(BrokerClient client, MessageAck ack)
           
 void DefaultBroker.startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction.
 void DefaultBroker.commitTransaction(BrokerClient client, java.lang.String transactionId)
          commit a transaction
 void DefaultBroker.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          rollback a transaction
 void DefaultBroker.startTransaction(BrokerClient client, ActiveMQXid xid)
          Starts an XA Transaction.
 int DefaultBroker.prepareTransaction(BrokerClient client, ActiveMQXid xid)
          Prepares an XA Transaciton.
 void DefaultBroker.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
          Rollback an XA Transaction.
 void DefaultBroker.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
          Commit an XA Transaction.
 void DefaultBroker.cleanUpClient(BrokerClient client)
          A hint to the broker that an BrokerClient has stopped This enables the broker to clean-up any outstanding processing that may be outstanding
 ActiveMQXid[] DefaultBroker.getPreparedTransactions(BrokerClient client)
          Gets the prepared XA transactions.
 void BrokerContainerImpl.registerConnection(BrokerClient client, ConnectionInfo info)
          registers a new Connection
 void BrokerContainerImpl.deregisterConnection(BrokerClient client, ConnectionInfo info)
          un-registers a Connection
 void BrokerContainerImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerContainerImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerContainerImpl.registerMessageProducer(BrokerClient client, ProducerInfo info)
          Registers a MessageProducer
 void BrokerContainerImpl.deregisterMessageProducer(BrokerClient client, ProducerInfo info)
          De-register a MessageProducer from the Broker
 void BrokerContainerImpl.registerSession(BrokerClient client, SessionInfo info)
          Register a client-side Session (used for Monitoring)
 void BrokerContainerImpl.deregisterSession(BrokerClient client, SessionInfo info)
          De-register a client-side Session from the Broker (used for monitoring)
 void BrokerContainerImpl.startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction from the Client session
 void BrokerContainerImpl.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          Rollback a transacton
 void BrokerContainerImpl.commitTransaction(BrokerClient client, java.lang.String transactionId)
          Commit a transaction
 void BrokerContainerImpl.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerContainerImpl.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge receipt of a message within a transaction context
 void BrokerContainerImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerContainerImpl.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge reciept of a message
 void BrokerContainerImpl.durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds)
          Command to delete a durable topic subscription
 void BrokerContainerImpl.startTransaction(BrokerClient client, ActiveMQXid xid)
          Start an XA transaction.
 ActiveMQXid[] BrokerContainerImpl.getPreparedTransactions(BrokerClient client)
          Gets the prepared XA transactions.
 int BrokerContainerImpl.prepareTransaction(BrokerClient client, ActiveMQXid xid)
          Prepare an XA transaction.
 void BrokerContainerImpl.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
          Rollback an XA transaction.
 void BrokerContainerImpl.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
          Commit an XA transaction.
 void BrokerConnectorImpl.registerClient(BrokerClient client, ConnectionInfo info)
          Register a Broker Client
 void BrokerConnectorImpl.deregisterClient(BrokerClient client, ConnectionInfo info)
          Deregister a Broker Client
 void BrokerConnectorImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerConnectorImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerConnectorImpl.registerMessageProducer(BrokerClient client, ProducerInfo info)
          Registers a MessageProducer
 void BrokerConnectorImpl.deregisterMessageProducer(BrokerClient client, ProducerInfo info)
          De-register a MessageProducer from the Broker
 void BrokerConnectorImpl.registerSession(BrokerClient client, SessionInfo info)
          Register a client-side Session (used for Monitoring)
 void BrokerConnectorImpl.deregisterSession(BrokerClient client, SessionInfo info)
          De-register a client-side Session from the Broker (used for monitoring)
 void BrokerConnectorImpl.startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction from the Client session
 void BrokerConnectorImpl.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          Rollback a transacton
 void BrokerConnectorImpl.commitTransaction(BrokerClient client, java.lang.String transactionId)
          Commit a transaction
 void BrokerConnectorImpl.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)
          send message with a transaction context
 void BrokerConnectorImpl.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          Acknowledge receipt of a message within a transaction context
 void BrokerConnectorImpl.sendMessage(BrokerClient client, ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void BrokerConnectorImpl.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge reciept of a message
 void BrokerConnectorImpl.durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds)
          Command to delete a durable topic subscription
 void BrokerConnectorImpl.startTransaction(BrokerClient client, ActiveMQXid xid)
          Start an XA transaction.
 ActiveMQXid[] BrokerConnectorImpl.getPreparedTransactions(BrokerClient client)
          Gets the prepared XA transactions.
 int BrokerConnectorImpl.prepareTransaction(BrokerClient client, ActiveMQXid xid)
          Prepare an XA transaction.
 void BrokerConnectorImpl.rollbackTransaction(BrokerClient client, ActiveMQXid xid)
          Rollback an XA transaction.
 void BrokerConnectorImpl.commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase)
          Commit an XA transaction.
 java.lang.String BrokerConnectorImpl.getResourceManagerId(BrokerClient client)
           
 

Uses of BrokerClient in org.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service with parameters of type BrokerClient
 Transaction TransactionManager.createLocalTransaction(BrokerClient client, java.lang.String txid)
           
 Transaction TransactionManager.createXATransaction(BrokerClient client, ActiveMQXid xid)
           
 void TransactionManager.cleanUpClient(BrokerClient client)
          A hint to the TransactionManager that an BrokerClient has stopped This enables the TransactionManager to rollback in progess transactions that the client created.
 void SubscriptionContainer.checkForDuplicateDurableSubscription(BrokerClient client, ConsumerInfo info)
          There is only meant to be a single durable subscription open for a given clientID and subscriber name; this method will check to ensure that a user doesn't try to subscribe twice for the same clientID and subscriber name.
 void MessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void MessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void MessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void MessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge a message as being read and consumed by the Consumer
 void MessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)
          Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue
 void MessageContainerManager.commitTransaction(BrokerClient client, java.lang.String transactionId)
          A hook when the transaction is about to be commited; so apply all outstanding commands to the Journal if using a Journal (transaction log)
 void MessageContainerManager.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          A hook when the transaction is about to be rolled back; so discard all outstanding commands that are pending to be written to the Journal
 void MessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
          This is a hook to notify the dispatcher for the clients subscription that we have acknowledged a message within a transaction but before the commit - so the message is not really being acknowledged here but this method is intended to be a hook to let the dispatcher know that we can now send another message to the client.
 void Dispatcher.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void Dispatcher.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 

Uses of BrokerClient in org.codehaus.activemq.service.boundedvm
 

Methods in org.codehaus.activemq.service.boundedvm with parameters of type BrokerClient
 void TransientTopicBoundedMessageManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add a consumer if appropiate
 void TransientTopicBoundedMessageManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void TransientTopicBoundedMessageManager.acknowledgeMessage(BrokerClient client, MessageAck ack)
           
 void TransientTopicBoundedMessageManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
           
 void TransientTopicBoundedMessageManager.redeliverMessage(BrokerClient client, MessageAck ack)
           
 void TransientTopicBoundedMessageManager.commitTransaction(BrokerClient client, java.lang.String transactionId)
          A hook when the transaction is about to be commited; so apply all outstanding commands to the Journal if using a Journal (transaction log)
 void TransientTopicBoundedMessageManager.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          A hook when the transaction is about to be rolled back; so discard all outstanding commands that are pending to be written to the Journal
 

Constructors in org.codehaus.activemq.service.boundedvm with parameters of type BrokerClient
TransientTopicBoundedMessageContainer(BrokerClient client, BoundedPacketQueue queue)
          Construct this beast
 

Uses of BrokerClient in org.codehaus.activemq.service.impl
 

Methods in org.codehaus.activemq.service.impl that return BrokerClient
protected  BrokerClient PacketTransactionTask.createBrokerClient(java.lang.String consumerId)
           
protected  BrokerClient PacketTransactionTask.getBrokerClient(java.lang.String consumerId)
           
 

Methods in org.codehaus.activemq.service.impl with parameters of type BrokerClient
 void TransientTopicMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 Transaction TransactionManagerImpl.createLocalTransaction(BrokerClient client, java.lang.String txid)
           
 Transaction TransactionManagerImpl.createXATransaction(BrokerClient client, ActiveMQXid xid)
           
 void TransactionManagerImpl.cleanUpClient(BrokerClient client)
           
 void SubscriptionContainerImpl.checkForDuplicateDurableSubscription(BrokerClient client, ConsumerInfo info)
           
 void QueueMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void QueueMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void QueueMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void QueueMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge a message as being read and consumed by the Consumer
 void QueueMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
           
 void QueueMessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)
           
 void QueueMessageContainerManager.commitTransaction(BrokerClient client, java.lang.String transactionId)
           
 void QueueMessageContainerManager.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
           
 void ProxyMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)
           
 void ProxyMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
           
 void ProxyMessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)
           
 void ProxyMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void ProxyMessageContainerManager.commitTransaction(BrokerClient client, java.lang.String transactionId)
           
 void ProxyMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void ProxyMessageContainerManager.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
           
 void ProxyMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void InitialImageMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void InitialImageMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
protected  void InitialImageMessageContainerManager.sendMatchingInitialImages(BrokerClient client, ConsumerInfo info, DestinationFilter filter)
           
 void DurableTopicMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DurableTopicMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DurableTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void DurableTopicMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge a message as being read and consumed byh the Consumer
 void DurableTopicMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)
           
 void DurableTopicMessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)
           
 void DurableTopicMessageContainerManager.commitTransaction(BrokerClient client, java.lang.String transactionId)
           
 void DurableTopicMessageContainerManager.rollbackTransaction(BrokerClient client, java.lang.String transactionId)
           
protected  void DurableTopicMessageContainerManager.doAddMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DispatchWorker.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void DispatchWorker.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void DispatcherImpl.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void DispatcherImpl.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 

Constructors in org.codehaus.activemq.service.impl with parameters of type BrokerClient
SendMessageTransactionTask(BrokerClient brokerClient, ActiveMQMessage message)
           
RedeliverMessageTransactionTask(BrokerClient brokerClient, MessageAck ack)
           
PacketTransactionTask(BrokerClient brokerClient, Packet packet)
           
MessageAckTransactionTask(BrokerClient brokerClient, MessageAck ack)
           
 



Copyright © 2004 Protique, Ltd.. All Rights Reserved.