Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## 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)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

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