|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface BrokerContainer
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 |
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 |
deregisterRemoteClientID(String remoteClientID)
deregister a remote clientID |
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 |
registerRemoteClientID(String remoteClientID)
register a remote clientID |
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 |
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.activemq.service.Service |
---|
start, stop |
Method Detail |
---|
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
void deregisterConnection(BrokerClient client, ConnectionInfo info) throws JMSException
client
- info
- infomation about the client-side Connection
JMSException
void 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 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
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 addConnector(BrokerConnector connector)
connector
- void removeConnector(BrokerConnector connector)
connector
- Broker getBroker()
List getTransportConnectors()
void setTransportConnectors(List transportConnectors)
List getNetworkConnectors()
NetworkConnector
instances used to communicate with the network of Broker
instances
void setNetworkConnectors(List networkConnectors)
PersistenceAdapter getPersistenceAdapter()
void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
DiscoveryAgent getDiscoveryAgent()
void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
SecurityAdapter getSecurityAdapter()
void setSecurityAdapter(SecurityAdapter securityAdapter)
NetworkConnector addNetworkConnector(String uri) throws JMSException
JMSException
NetworkConnector addNetworkConnector()
void addNetworkConnector(NetworkConnector connector)
void removeNetworkConnector(NetworkConnector connector)
void addConnector(String bindAddress) throws JMSException
JMSException
void addConnector(String bindAddress, WireFormat wireFormat) throws JMSException
JMSException
void addConnector(TransportServerChannel transportConnector)
void registerRemoteClientID(String remoteClientID)
remoteClientID
- void deregisterRemoteClientID(String remoteClientID)
remoteClientID
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |