|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Broker
The Message Broker which routes messages, maintains subscriptions and connections, acknowledges messages and handles transactions.
Method Summary | |
---|---|
void |
addBroker(Connection connection,
BrokerInfo info)
A remote Broker connects |
void |
addConnection(ConnectionContext context,
ConnectionInfo info)
A client is establishing a connection with the broker. |
void |
addDestinationInfo(ConnectionContext context,
DestinationInfo info)
Add and process a DestinationInfo object |
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer. |
void |
addSession(ConnectionContext context,
SessionInfo info)
Adds a session. |
void |
beginTransaction(ConnectionContext context,
TransactionId xid)
Starts a transaction. |
void |
commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase)
Commits a transaction. |
void |
forgetTransaction(ConnectionContext context,
TransactionId transactionId)
Forgets a transaction. |
Broker |
getAdaptor(Class type)
Get a Broker from the Broker Stack that is a particular class |
ConnectionContext |
getAdminConnectionContext()
|
BrokerId |
getBrokerId()
Get the id of the broker |
String |
getBrokerName()
Get the name of the broker |
Connection[] |
getClients()
|
ActiveMQDestination[] |
getDestinations()
|
Set |
getDurableDestinations()
|
BrokerInfo[] |
getPeerBrokerInfos()
Get the BrokerInfo's of any connected Brokers |
PendingDurableSubscriberMessageStoragePolicy |
getPendingDurableSubscriberPolicy()
|
TransactionId[] |
getPreparedTransactions(ConnectionContext context)
Gets a list of all the prepared xa transactions. |
Store |
getTempDataStore()
|
boolean |
isFaultTolerantConfiguration()
|
boolean |
isSlaveBroker()
|
boolean |
isStopped()
|
int |
prepareTransaction(ConnectionContext context,
TransactionId xid)
Prepares a transaction. |
void |
processDispatch(MessageDispatch messageDispatch)
Notify the Broker that a dispatch has happened |
void |
removeBroker(Connection connection,
BrokerInfo info)
Remove a BrokerInfo |
void |
removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error)
A client is disconnecting from the broker. |
void |
removeDestinationInfo(ConnectionContext context,
DestinationInfo info)
Remove and process a DestinationInfo object |
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a producer. |
void |
removeSession(ConnectionContext context,
SessionInfo info)
Removes a session. |
void |
rollbackTransaction(ConnectionContext context,
TransactionId xid)
Rollsback a transaction. |
void |
setAdminConnectionContext(ConnectionContext adminConnectionContext)
Sets the default administration connection context used when configuring the broker on startup or via JMX |
void |
setPendingDurableSubscriberPolicy(PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy)
|
Methods inherited from interface org.apache.activemq.broker.region.Region |
---|
acknowledge, addConsumer, addDestination, gc, getDestinationMap, getDestinations, messagePull, processDispatchNotification, removeConsumer, removeDestination, removeSubscription, send |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
Broker getAdaptor(Class type)
type
-
BrokerId getBrokerId()
context
- info
- client
- String getBrokerName()
void addBroker(Connection connection, BrokerInfo info)
contection
- info
- client
- void removeBroker(Connection connection, BrokerInfo info)
connection
- info
- void addConnection(ConnectionContext context, ConnectionInfo info) throws Exception
context
- info
- client
-
Exception
- TODOvoid removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error) throws Exception
context
- the environment the operation is being executed under.info
- client
- error
- null if the client requested the disconnect or the error that caused the client to disconnect.
Exception
- TODOvoid addSession(ConnectionContext context, SessionInfo info) throws Exception
context
- info
-
Exception
- TODOvoid removeSession(ConnectionContext context, SessionInfo info) throws Exception
context
- info
-
Exception
- TODOvoid addProducer(ConnectionContext context, ProducerInfo info) throws Exception
context
- the enviorment the operation is being executed under.
Exception
- TODOvoid removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
context
- the enviorment the operation is being executed under.
Exception
- TODOConnection[] getClients() throws Exception
Exception
- TODOActiveMQDestination[] getDestinations() throws Exception
Exception
- TODOTransactionId[] getPreparedTransactions(ConnectionContext context) throws Exception
client
-
Exception
- TODOvoid beginTransaction(ConnectionContext context, TransactionId xid) throws Exception
client
- xid
-
Exception
- TODOint prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception
client
- xid
-
Exception
- TODOvoid rollbackTransaction(ConnectionContext context, TransactionId xid) throws Exception
client
- xid
-
Exception
- TODOvoid commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception
client
- xid
- onePhase
-
Exception
- TODOvoid forgetTransaction(ConnectionContext context, TransactionId transactionId) throws Exception
client
- xid
- onePhase
-
Exception
- TODOBrokerInfo[] getPeerBrokerInfos()
void processDispatch(MessageDispatch messageDispatch)
messageDispatch
- boolean isSlaveBroker()
boolean isStopped()
Set getDurableDestinations()
void addDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
context
- info
-
Exception
void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
context
- info
-
Exception
boolean isFaultTolerantConfiguration()
ConnectionContext getAdminConnectionContext()
void setAdminConnectionContext(ConnectionContext adminConnectionContext)
adminConnectionContext
- PendingDurableSubscriberMessageStoragePolicy getPendingDurableSubscriberPolicy()
void setPendingDurableSubscriberPolicy(PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy)
pendingDurableSubscriberPolicy
- the pendingDurableSubscriberPolicy to setStore getTempDataStore()
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |