|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
The ActiveMQ JMS Broker Container which contains a Broker
and one or more
instances talking over some TransportChannel
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 |
addConnector(BrokerConnector connector)
Called when a new connector is added to this container |
void |
addConnector(String bindAddress)
Adds a new transport connector for the given bind address |
void |
addConnector(String bindAddress,
WireFormat wireFormat)
Adds a new transport connector for the given bind address and wire format |
void |
addConnector(TransportServerChannel transportConnector)
Adds a new transport connector for the given transportConnector |
NetworkConnector |
addNetworkConnector()
Adds a new network connector |
void |
addNetworkConnector(NetworkConnector connector)
Adds a new network connector |
NetworkConnector |
addNetworkConnector(String uri)
Adds a new network connector for the given URI |
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
Commit an XA transaction. |
void |
commitTransaction(BrokerClient client,
String transactionId)
Commit a transaction |
void |
deregisterConnection(BrokerClient client,
ConnectionInfo info)
un-registers a Connection |
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 |
Broker |
getBroker()
|
DiscoveryAgent |
getDiscoveryAgent()
Returns the discovery agent if one is available or null if discovery is not enabled |
List |
getNetworkConnectors()
Returns a list of NetworkConnector
instances used to communicate with the network of Broker instances |
PersistenceAdapter |
getPersistenceAdapter()
Returns the persistence adapter |
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
Gets the prepared XA transactions. |
SecurityAdapter |
getSecurityAdapter()
Returns the security adapter used to authenticate and authorize access to JMS resources |
List |
getTransportConnectors()
Returns the transport connectors used to communicate with clients |
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
Prepare an XA transaction. |
void |
registerConnection(BrokerClient client,
ConnectionInfo info)
registers a new Connection |
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 |
removeConnector(BrokerConnector connector)
Called when a connector is removed to this container |
void |
removeNetworkConnector(NetworkConnector connector)
Removes the given network connector |
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 |
setDiscoveryAgent(DiscoveryAgent discoveryAgent)
|
void |
setNetworkConnectors(List networkConnectors)
|
void |
setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
|
void |
setSecurityAdapter(SecurityAdapter securityAdapter)
Sets the security adapter used to authenticate and authorize access to JMS resources |
void |
setTransportConnectors(List transportConnectors)
|
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 void registerConnection(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
- infomation about the client-side Connection
InvalidClientIDException
- if the ClientID of the Connection is a duplicate
JMSException
public void deregisterConnection(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
- infomation about the client-side Connection
JMSException
public 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 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 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 addConnector(BrokerConnector connector)
connector
- public void removeConnector(BrokerConnector connector)
connector
- public Broker getBroker()
public List getTransportConnectors()
public void setTransportConnectors(List transportConnectors)
public List getNetworkConnectors()
NetworkConnector
instances used to communicate with the network of Broker
instances
public void setNetworkConnectors(List networkConnectors)
public PersistenceAdapter getPersistenceAdapter()
public void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
public DiscoveryAgent getDiscoveryAgent()
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
public SecurityAdapter getSecurityAdapter()
public void setSecurityAdapter(SecurityAdapter securityAdapter)
public NetworkConnector addNetworkConnector(String uri)
public NetworkConnector addNetworkConnector()
public void addNetworkConnector(NetworkConnector connector)
public void removeNetworkConnector(NetworkConnector connector)
public void addConnector(String bindAddress) throws JMSException
JMSException
public void addConnector(String bindAddress, WireFormat wireFormat) throws JMSException
JMSException
public void addConnector(TransportServerChannel transportConnector)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |