|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
The Broker is the client side interface to the JMS server
Method Summary | |
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge receipt of a message within a transaction context |
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
Commit an XA transaction. |
void |
commitTransaction(BrokerClient client,
String transactionId)
Commit a transaction |
void |
deregisterClient(BrokerClient client,
ConnectionInfo info)
Deregister a Broker Client |
void |
deregisterMessageConsumer(BrokerClient client,
ConsumerInfo info)
De-register a MessageConsumer from the Broker |
void |
deregisterMessageProducer(BrokerClient client,
ProducerInfo info)
De-register a MessageProducer from the Broker |
void |
deregisterSession(BrokerClient client,
SessionInfo info)
De-register a client-side Session from the Broker (used for monitoring) |
void |
durableUnsubscribe(BrokerClient client,
DurableUnsubscribe ds)
Command to delete a durable topic subscription |
int |
getBrokerCapacity()
Get a hint about the broker capacity for more messages |
BrokerContainer |
getBrokerContainer()
|
BrokerInfo |
getBrokerInfo()
|
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
Get all the Xids of the prepared XA transactions. |
String |
getResourceManagerId(BrokerClient client)
Gets the unique id of the resource manager used for managing xa transactions. |
TransportServerChannel |
getServerChannel()
|
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
Prepare an XA transaction. |
void |
registerClient(BrokerClient client,
ConnectionInfo info)
Register a Broker Client |
void |
registerMessageConsumer(BrokerClient client,
ConsumerInfo info)
Registers a MessageConsumer |
void |
registerMessageProducer(BrokerClient client,
ProducerInfo info)
Registers a MessageProducer |
void |
registerSession(BrokerClient client,
SessionInfo info)
Register a client-side Session (used for Monitoring) |
void |
rollbackTransaction(BrokerClient client,
ActiveMQXid xid)
Rollback an XA transaction. |
void |
rollbackTransaction(BrokerClient client,
String transactionId)
Rollback a transacton |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send message with a transaction context |
void |
startTransaction(BrokerClient client,
ActiveMQXid xid)
Start an XA transaction |
void |
startTransaction(BrokerClient client,
String transactionId)
Start a transaction from the Client session |
Methods inherited from interface org.codehaus.activemq.service.Service |
start, stop |
Method Detail |
public BrokerInfo getBrokerInfo()
public TransportServerChannel getServerChannel()
public int getBrokerCapacity()
public void registerClient(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
- contains infomation about the Connection this Client
represents
JMSException
InvalidClientIDException
- if the JMS client specifies an invalid or duplicate client
ID.
JMSSecurityException
- if client authentication fails due to an invalid user name or
password.public void deregisterClient(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
-
JMSException
- if some internal error occurspublic void registerMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
JMSSecurityException
- if client authentication fails for the Destination the
Consumer applies forpublic void deregisterMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
public void registerMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
client
- info
-
JMSException
JMSSecurityException
- if client authentication fails for the Destination the
Consumer applies forpublic void deregisterMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
client
- info
-
JMSException
public void registerSession(BrokerClient client, SessionInfo info) throws JMSException
client
- info
-
JMSException
public void deregisterSession(BrokerClient client, SessionInfo info) throws JMSException
client
- info
-
JMSException
public void startTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void rollbackTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void commitTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void startTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
public ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws XAException
client
-
XAException
public int prepareTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
public void rollbackTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
public void commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase) throws XAException
client
- xid
- onePhase
-
XAException
public void sendTransactedMessage(BrokerClient client, String transactionId, ActiveMQMessage message) throws JMSException
client
- transactionId
- message
-
JMSException
public void acknowledgeTransactedMessage(BrokerClient client, String transactionId, MessageAck ack) throws JMSException
client
- transactionId
- ack
-
JMSException
public void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
client
- message
-
JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
public void durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds) throws JMSException
client
- ds
-
JMSException
public String getResourceManagerId(BrokerClient client)
client
-
public BrokerContainer getBrokerContainer()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |