Overview  Package  Class   Use  Deprecated  Index
Home >> All >> org >> activemq >> [ broker overview ]	PREV  NEXT

---

Uses of Interface
org.activemq.broker.BrokerClient

Uses of BrokerClient in org.activemq.broker

 

Classes in org.activemq.broker that implement BrokerClient
class	BrokerClientStub           A mock dispatcher for testing

 

Methods in org.activemq.broker with parameters of type BrokerClient
void	ConsumerInfoListener.onConsumerInfo(BrokerClient client, org.activemq.message.ConsumerInfo info)           ConsumerInfo packet fired from within the broker
void	BrokerContainer.registerConnection(BrokerClient client, org.activemq.message.ConnectionInfo info)           registers a new Connection
void	BrokerContainer.deregisterConnection(BrokerClient client, org.activemq.message.ConnectionInfo info)           un-registers a Connection
void	BrokerContainer.registerMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           Registers a MessageConsumer
void	BrokerContainer.deregisterMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           De-register a MessageConsumer from the Broker
void	BrokerContainer.registerMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           Registers a MessageProducer
void	BrokerContainer.deregisterMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           De-register a MessageProducer from the Broker
void	BrokerContainer.registerSession(BrokerClient client, org.activemq.message.SessionInfo info)           Register a client-side Session (used for Monitoring)
void	BrokerContainer.deregisterSession(BrokerClient client, org.activemq.message.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.sendMessage(BrokerClient client, org.activemq.message.ActiveMQMessage message)           Send a non-transacted message to the Broker
void	BrokerContainer.acknowledgeMessage(BrokerClient client, org.activemq.message.MessageAck ack)           Acknowledge reciept of a message
void	BrokerContainer.durableUnsubscribe(BrokerClient client, org.activemq.message.DurableUnsubscribe ds)           Command to delete a durable topic subscription
void	BrokerContainer.startTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Start an XA transaction.
org.activemq.message.ActiveMQXid[]	BrokerContainer.getPreparedTransactions(BrokerClient client)           Gets the prepared XA transactions.
int	BrokerContainer.prepareTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Prepare an XA transaction.
void	BrokerContainer.rollbackTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Rollback an XA transaction.
void	BrokerContainer.commitTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid, boolean onePhase)           Commit an XA transaction.
void	BrokerConnector.registerClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           Register a Broker Client
void	BrokerConnector.deregisterClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           Deregister a Broker Client
void	BrokerConnector.registerMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           Registers a MessageConsumer
void	BrokerConnector.deregisterMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           De-register a MessageConsumer from the Broker
void	BrokerConnector.registerMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           Registers a MessageProducer
void	BrokerConnector.deregisterMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           De-register a MessageProducer from the Broker
void	BrokerConnector.registerSession(BrokerClient client, org.activemq.message.SessionInfo info)           Register a client-side Session (used for Monitoring)
void	BrokerConnector.deregisterSession(BrokerClient client, org.activemq.message.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, org.activemq.message.ActiveMQXid xid)           Start an XA transaction
org.activemq.message.ActiveMQXid[]	BrokerConnector.getPreparedTransactions(BrokerClient client)           Get all the Xids of the prepared XA transactions.
int	BrokerConnector.prepareTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Prepare an XA transaction.
void	BrokerConnector.rollbackTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Rollback an XA transaction.
void	BrokerConnector.commitTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid, boolean onePhase)           Commit an XA transaction.
void	BrokerConnector.sendMessage(BrokerClient client, org.activemq.message.ActiveMQMessage message)           Send a non-transacted message to the Broker
void	BrokerConnector.acknowledgeMessage(BrokerClient client, org.activemq.message.MessageAck ack)           Acknowledge reciept of a message
void	BrokerConnector.durableUnsubscribe(BrokerClient client, org.activemq.message.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.addClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           Notification of a new client attempting to connect, which can be rejected if authentication or authorization fails.
void	Broker.removeClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           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.addMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           Adds a new message producer, which could be rejected due to authorization
void	Broker.removeMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           Removes a producer
void	Broker.addMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           Add an active message consumer, which could be rejected due to authorization
void	Broker.removeMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           remove an active message consumer
void	Broker.sendMessage(BrokerClient client, org.activemq.message.ActiveMQMessage message)           send a message to the broker
void	Broker.acknowledgeMessage(BrokerClient client, org.activemq.message.MessageAck ack)           Acknowledge positively or negatively, the consumption of a message by the Message Consumer
org.activemq.message.ActiveMQXid[]	Broker.getPreparedTransactions(BrokerClient client)           gets a list of all the prepared xa transactions.
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, org.activemq.message.ActiveMQXid xid)
int	Broker.prepareTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)
void	Broker.rollbackTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)
void	Broker.commitTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid, boolean onePhase)

 

---

Overview  Package  Class   Use  Deprecated  Index
Home >> All >> org >> activemq >> [ broker overview ]	PREV  NEXT

---