|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
The Message Broker which routes messages, maintains subscriptions and connections, acknowlegdges messages and handles transactions.
Nested Class Summary |
Nested classes inherited from class org.codehaus.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 |
acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge positively or negatively, the consumption of a message within a transaction |
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()
|
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 |
redeliverMessage(BrokerClient client,
MessageAck ack)
Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue |
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 |
sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send a message to the broker within a transaction |
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.codehaus.activemq.service.Service |
start, stop |
Methods inherited from interface org.codehaus.activemq.capacity.CapacityMonitor |
addCapacityEventListener, generateCapacityMonitorEvent, getCurrentCapacity, getCurrentValue, getName, getRoundedCapacity, getRoundingFactor, getValueLimit, removeCapacityEventListener, setCurrentValue, setName, setRoundingFactor, setValueLimit |
Method Detail |
public BrokerAdmin getBrokerAdmin()
public void addClient(BrokerClient client, ConnectionInfo info) throws JMSException
JMSException
public void removeClient(BrokerClient client, ConnectionInfo info) throws JMSException
JMSException
public void addMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
JMSException
public void removeMessageProducer(BrokerClient client, ProducerInfo info) throws JMSException
JMSException
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
public void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
JMSException
public void sendTransactedMessage(BrokerClient client, String transactionId, ActiveMQMessage message) throws JMSException
JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
JMSException
public void acknowledgeTransactedMessage(BrokerClient client, String transactionId, MessageAck ack) throws JMSException
JMSException
public ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws XAException
client
-
XAException
public void redeliverMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
public void deleteSubscription(String clientId, String subscriberName) throws JMSException
clientId
- subscriberName
-
JMSException
- if the subscriber doesn't exist or is still activepublic void startTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void commitTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void rollbackTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void startTransaction(BrokerClient client, ActiveMQXid xid) throws XAException
client
- xid
-
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 File getTempDir()
public String getBrokerName()
public String getBrokerClusterName()
public PersistenceAdapter getPersistenceAdapter()
public void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
persistenceAdapter
- public Map getContainerManagerMap()
public Context getDestinationContext(Hashtable environment)
environment
-
public void addConsumerInfoListener(ConsumerInfoListener l)
l
- public void removeConsumerInfoListener(ConsumerInfoListener l)
l
- public MessageContainerManager getPersistentTopicContainerManager()
public MessageContainerManager getTransientTopicContainerManager()
public MessageContainerManager getPersistentQueueContainerManager()
public MessageContainerManager getTransientQueueContainerManager()
public SecurityAdapter getSecurityAdapter()
public void setSecurityAdapter(SecurityAdapter securityAdapter)
public RedeliveryPolicy getRedeliveryPolicy()
public void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
redeliveryPolicy
- public DeadLetterPolicy getDeadLetterPolicy()
public void setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
deadLetterPolicy
- public 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 |