|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface BrokerConnector
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 |
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 |
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.activemq.service.Service |
---|
start, stop |
Method Detail |
---|
BrokerInfo getBrokerInfo()
TransportServerChannel getServerChannel()
int getBrokerCapacity()
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.void deregisterClient(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
-
JMSException
- if some internal error occursvoid registerMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
JMSSecurityException
- if client authentication fails for the Destination the
Consumer applies forvoid deregisterMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
void registerMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
client
- info
-
JMSException
JMSSecurityException
- if client authentication fails for the Destination the
Consumer applies forvoid deregisterMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
client
- info
-
JMSException
void registerSession(BrokerClient client, SessionInfo info) throws JMSException
client
- info
-
JMSException
void deregisterSession(BrokerClient client, SessionInfo info) throws JMSException
client
- info
-
JMSException
void startTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void rollbackTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void commitTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void startTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws XAException
client
-
XAException
int prepareTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
void rollbackTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
XAException
void commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase) throws XAException
client
- xid
- onePhase
-
XAException
void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
client
- message
-
JMSException
void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
void durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds) throws JMSException
client
- ds
-
JMSException
String getResourceManagerId(BrokerClient client)
client
-
BrokerContainer getBrokerContainer()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |