Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ broker overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.broker
Interface BrokerConnector  

All Superinterfaces:

org.activemq.service.Service

---

public interface BrokerConnector

extends org.activemq.service.Service

The Broker is the client side interface to the JMS server

Version:

$Revision: 1.1.1.1 $

---

Method Summary
void	acknowledgeMessage(BrokerClient client, org.activemq.message.MessageAck ack)           Acknowledge reciept of a message
void	commitTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid, boolean onePhase)           Commit an XA transaction.
void	commitTransaction(BrokerClient client, java.lang.String transactionId)           Commit a transaction
void	deregisterClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           Deregister a Broker Client
void	deregisterMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           De-register a MessageConsumer from the Broker
void	deregisterMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           De-register a MessageProducer from the Broker
void	deregisterSession(BrokerClient client, org.activemq.message.SessionInfo info)           De-register a client-side Session from the Broker (used for monitoring)
void	durableUnsubscribe(BrokerClient client, org.activemq.message.DurableUnsubscribe ds)           Command to delete a durable topic subscription
int	getBrokerCapacity()           Get a hint about the broker capacity for more messages
BrokerContainer	getBrokerContainer()
org.activemq.message.BrokerInfo	getBrokerInfo()
org.activemq.message.ActiveMQXid[]	getPreparedTransactions(BrokerClient client)           Get all the Xids of the prepared XA transactions.
java.lang.String	getResourceManagerId(BrokerClient client)           Gets the unique id of the resource manager used for managing xa transactions.
org.activemq.transport.TransportServerChannel	getServerChannel()
int	prepareTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Prepare an XA transaction.
void	registerClient(BrokerClient client, org.activemq.message.ConnectionInfo info)           Register a Broker Client
void	registerMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)           Registers a MessageConsumer
void	registerMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)           Registers a MessageProducer
void	registerSession(BrokerClient client, org.activemq.message.SessionInfo info)           Register a client-side Session (used for Monitoring)
void	rollbackTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Rollback an XA transaction.
void	rollbackTransaction(BrokerClient client, java.lang.String transactionId)           Rollback a transacton
void	sendMessage(BrokerClient client, org.activemq.message.ActiveMQMessage message)           Send a non-transacted message to the Broker
void	startTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)           Start an XA transaction
void	startTransaction(BrokerClient client, java.lang.String transactionId)           Start a transaction from the Client session

 

Methods inherited from interface org.activemq.service.Service

start, stop

 

Method Detail

getBrokerInfo

public org.activemq.message.BrokerInfo getBrokerInfo()

---

getServerChannel

public org.activemq.transport.TransportServerChannel getServerChannel()

---

getBrokerCapacity

public int getBrokerCapacity()

Get a hint about the broker capacity for more messages

---

registerClient

public void registerClient(BrokerClient client,
                           org.activemq.message.ConnectionInfo info)
                    throws javax.jms.JMSException

Register a Broker Client

---

deregisterClient

public void deregisterClient(BrokerClient client,
                             org.activemq.message.ConnectionInfo info)
                      throws javax.jms.JMSException

Deregister a Broker Client

---

registerMessageConsumer

public void registerMessageConsumer(BrokerClient client,
                                    org.activemq.message.ConsumerInfo info)
                             throws javax.jms.JMSException

Registers a MessageConsumer

---

deregisterMessageConsumer

public void deregisterMessageConsumer(BrokerClient client,
                                      org.activemq.message.ConsumerInfo info)
                               throws javax.jms.JMSException

De-register a MessageConsumer from the Broker

---

registerMessageProducer

public void registerMessageProducer(BrokerClient client,
                                    org.activemq.message.ProducerInfo info)
                             throws javax.jms.JMSException

Registers a MessageProducer

---

deregisterMessageProducer

public void deregisterMessageProducer(BrokerClient client,
                                      org.activemq.message.ProducerInfo info)
                               throws javax.jms.JMSException

De-register a MessageProducer from the Broker

---

registerSession

public void registerSession(BrokerClient client,
                            org.activemq.message.SessionInfo info)
                     throws javax.jms.JMSException

Register a client-side Session (used for Monitoring)

---

deregisterSession

public void deregisterSession(BrokerClient client,
                              org.activemq.message.SessionInfo info)
                       throws javax.jms.JMSException

De-register a client-side Session from the Broker (used for monitoring)

---

startTransaction

public void startTransaction(BrokerClient client,
                             java.lang.String transactionId)
                      throws javax.jms.JMSException

Start a transaction from the Client session

---

rollbackTransaction

public void rollbackTransaction(BrokerClient client,
                                java.lang.String transactionId)
                         throws javax.jms.JMSException

Rollback a transacton

---

commitTransaction

public void commitTransaction(BrokerClient client,
                              java.lang.String transactionId)
                       throws javax.jms.JMSException

Commit a transaction

---

startTransaction

public void startTransaction(BrokerClient client,
                             org.activemq.message.ActiveMQXid xid)
                      throws javax.transaction.xa.XAException

Start an XA transaction

---

getPreparedTransactions

public org.activemq.message.ActiveMQXid[] getPreparedTransactions(BrokerClient client)
                                                           throws javax.transaction.xa.XAException

Get all the Xids of the prepared XA transactions.

---

prepareTransaction

public int prepareTransaction(BrokerClient client,
                              org.activemq.message.ActiveMQXid xid)
                       throws javax.transaction.xa.XAException

Prepare an XA transaction.

---

rollbackTransaction

public void rollbackTransaction(BrokerClient client,
                                org.activemq.message.ActiveMQXid xid)
                         throws javax.transaction.xa.XAException

Rollback an XA transaction.

---

commitTransaction

public void commitTransaction(BrokerClient client,
                              org.activemq.message.ActiveMQXid xid,
                              boolean onePhase)
                       throws javax.transaction.xa.XAException

Commit an XA transaction.

---

sendMessage

public void sendMessage(BrokerClient client,
                        org.activemq.message.ActiveMQMessage message)
                 throws javax.jms.JMSException

Send a non-transacted message to the Broker

---

acknowledgeMessage

public void acknowledgeMessage(BrokerClient client,
                               org.activemq.message.MessageAck ack)
                        throws javax.jms.JMSException

Acknowledge reciept of a message

---

durableUnsubscribe

public void durableUnsubscribe(BrokerClient client,
                               org.activemq.message.DurableUnsubscribe ds)
                        throws javax.jms.JMSException

Command to delete a durable topic subscription

---

getResourceManagerId

public java.lang.String getResourceManagerId(BrokerClient client)

Gets the unique id of the resource manager used for managing xa transactions.

---

getBrokerContainer

public BrokerContainer getBrokerContainer()

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ broker overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---