|
||||||||||
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, acknowlegdges messages and handles transactions.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.activemq.capacity.CapacityMonitor |
---|
CapacityMonitor.BasicCapacityMonitor |
Method Summary | |
---|---|
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge positively or negatively, the consumption of a message by the Message Consumer |
void |
addClient(BrokerClient client,
ConnectionInfo info)
Notification of a new client attempting to connect, which can be rejected if authentication or authorization fails. |
void |
addConsumerInfoListener(ConsumerInfoListener l)
Add a ConsumerInfoListener to the Broker |
void |
addMessageConsumer(BrokerClient client,
ConsumerInfo info)
Add an active message consumer, which could be rejected due to authorization |
void |
addMessageProducer(BrokerClient client,
ProducerInfo info)
Adds a new message producer, which could be rejected due to authorization |
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
|
void |
commitTransaction(BrokerClient client,
String transactionId)
commit a transaction |
void |
deleteSubscription(String clientId,
String subscriberName)
Delete a durable subscriber |
BrokerAdmin |
getBrokerAdmin()
Get's the admin interface of the broker. |
String |
getBrokerClusterName()
|
BrokerInfo |
getBrokerInfo()
|
String |
getBrokerName()
|
Map |
getContainerManagerMap()
|
DeadLetterPolicy |
getDeadLetterPolicy()
|
Context |
getDestinationContext(Hashtable environment)
Returns the naming context of the destinations available in this broker |
PersistenceAdapter |
getPersistenceAdapter()
|
MessageContainerManager |
getPersistentQueueContainerManager()
|
MessageContainerManager |
getPersistentTopicContainerManager()
|
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
gets a list of all the prepared xa transactions. |
RedeliveryPolicy |
getRedeliveryPolicy()
|
SecurityAdapter |
getSecurityAdapter()
Returns the security adapter used to authenticate and authorize access to JMS resources |
File |
getTempDir()
Get a temp directory - used for spooling |
MessageContainerManager |
getTransientQueueContainerManager()
|
MessageContainerManager |
getTransientTopicContainerManager()
|
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
|
void |
removeClient(BrokerClient client,
ConnectionInfo info)
A hint to the broker that an BrokerClient has stopped This enables the broker to clean-up any outstanding processing that may be outstanding |
void |
removeConsumerInfoListener(ConsumerInfoListener l)
Remove a ConsumerInfoListener from the Broker |
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
remove an active message consumer |
void |
removeMessageProducer(BrokerClient client,
ProducerInfo info)
Removes a producer |
void |
rollbackTransaction(BrokerClient client,
ActiveMQXid xid)
|
void |
rollbackTransaction(BrokerClient client,
String transactionId)
rollback a transaction |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
void |
setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
set the dead letter policy |
void |
setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
set the persistence adaptor |
void |
setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
set the redelivery policy |
void |
setSecurityAdapter(SecurityAdapter securityAdapter)
Sets the security adapter used to authenticate and authorize access to JMS resources |
void |
startTransaction(BrokerClient client,
ActiveMQXid xid)
|
void |
startTransaction(BrokerClient client,
String transactionId)
start a transaction |
Methods inherited from interface org.activemq.service.Service |
---|
start, stop |
Methods inherited from interface org.activemq.capacity.CapacityMonitor |
---|
addCapacityEventListener, generateCapacityMonitorEvent, getCurrentCapacity, getCurrentValue, getName, getRoundedCapacity, getRoundingFactor, getValueLimit, removeCapacityEventListener, setCurrentValue, setName, setRoundingFactor, setValueLimit |
Method Detail |
---|
BrokerAdmin getBrokerAdmin()
BrokerInfo getBrokerInfo()
void addClient(BrokerClient client, ConnectionInfo info) throws JMSException
JMSException
void removeClient(BrokerClient client, ConnectionInfo info) throws JMSException
JMSException
void addMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
JMSException
void removeMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
JMSException
void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
JMSException
void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
JMSException
ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws XAException
client
-
XAException
void deleteSubscription(String clientId, String subscriberName) throws JMSException
clientId
- subscriberName
-
JMSException
- if the subscriber doesn't exist or is still activevoid startTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void commitTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void rollbackTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
void startTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
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
File getTempDir()
String getBrokerName()
String getBrokerClusterName()
PersistenceAdapter getPersistenceAdapter()
void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
persistenceAdapter
- Map getContainerManagerMap()
Context getDestinationContext(Hashtable environment)
environment
-
void addConsumerInfoListener(ConsumerInfoListener l)
l
- void removeConsumerInfoListener(ConsumerInfoListener l)
l
- MessageContainerManager getPersistentTopicContainerManager()
MessageContainerManager getTransientTopicContainerManager()
MessageContainerManager getPersistentQueueContainerManager()
MessageContainerManager getTransientQueueContainerManager()
SecurityAdapter getSecurityAdapter()
void setSecurityAdapter(SecurityAdapter securityAdapter)
RedeliveryPolicy getRedeliveryPolicy()
void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
redeliveryPolicy
- DeadLetterPolicy getDeadLetterPolicy()
void setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
deadLetterPolicy
- void sendToDeadLetterQueue(String deadLetterName, ActiveMQMessage message) throws JMSException
deadLetterName
- message
-
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |