|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.capacity.DelegateCapacityMonitor
org.activemq.broker.impl.DefaultBroker
The default Broker
implementation
Nested Class Summary |
Nested classes inherited from class org.activemq.capacity.CapacityMonitor |
CapacityMonitor.BasicCapacityMonitor |
Field Summary | |
protected static java.lang.Class[] |
NEWINSTANCE_PARAMETER_TYPES
|
protected static java.lang.String |
PERSISTENCE_ADAPTER_FACTORY
|
protected static java.lang.String |
PROPERTY_STORE_DIRECTORY
|
Constructor Summary | |
DefaultBroker(java.lang.String brokerName)
|
|
DefaultBroker(java.lang.String brokerName,
MemoryBoundedObjectManager memoryManager)
|
|
DefaultBroker(java.lang.String brokerName,
PersistenceAdapter persistenceAdapter)
|
|
DefaultBroker(java.lang.String brokerName,
java.lang.String cluserName)
|
|
DefaultBroker(java.lang.String brokerName,
java.lang.String brokerClusterName,
MemoryBoundedObjectManager memoryManager)
|
|
DefaultBroker(java.lang.String brokerName,
java.lang.String brokerClusterName,
PersistenceAdapter persistenceAdapter)
|
Method Summary | |
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge 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 |
void |
addMessageProducer(BrokerClient client,
ProducerInfo info)
Adds a new message producer, which could be rejected due to authorization |
protected void |
checkValid()
|
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
Commit an XA Transaction. |
void |
commitTransaction(BrokerClient client,
java.lang.String transactionId)
commit a transaction |
protected MessageContainerManager[] |
createContainerManagers()
Factory method to create the default container managers |
protected javax.jms.JMSException |
createInstantiateAdapterException(java.lang.String className,
java.lang.Throwable e)
|
void |
createMessageContainer(ActiveMQDestination dest)
|
protected PersistenceAdapter |
createPersistenceAdapter()
Factory method to create a default persistence adapter |
void |
deleteSubscription(java.lang.String clientId,
java.lang.String subscriberName)
Delete a durable subscriber |
void |
destoryMessageContainer(ActiveMQDestination dest)
|
protected void |
doMessageSend(BrokerClient client,
ActiveMQMessage message)
|
protected void |
fireConsumerInfo(BrokerClient client,
ConsumerInfo info)
|
BrokerAdmin |
getBrokerAdmin()
Get's the admin interface of the broker. |
java.lang.String |
getBrokerClusterName()
|
java.lang.String |
getBrokerName()
|
java.util.Map |
getContainerManagerMap()
|
MessageContainerManager[] |
getContainerManagers()
|
DeadLetterPolicy |
getDeadLetterPolicy()
|
javax.naming.Context |
getDestinationContext(java.util.Hashtable environment)
Returns the naming context of the destinations available in this broker |
long |
getMaximumMemoryUsage()
|
MemoryBoundedObjectManager |
getMemoryManager()
|
MessageContainerAdmin |
getMessageContainerAdmin(ActiveMQDestination dest)
|
java.lang.String |
getName()
Get the name of the CapacityMonitor |
PersistenceAdapter |
getPersistenceAdapter()
|
MessageContainerManager |
getPersistentQueueContainerManager()
|
MessageContainerManager |
getPersistentTopicContainerManager()
|
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
Gets the prepared XA transactions. |
TransactionStore |
getPreparedTransactionStore()
|
MemoryBoundedQueueManager |
getQueueManager()
|
RedeliveryPolicy |
getRedeliveryPolicy()
|
SecurityAdapter |
getSecurityAdapter()
Returns the security adapter used to authenticate and authorize access to JMS resources |
protected java.lang.String |
getStoreDirectory()
|
java.io.File |
getTempDir()
Get a temp directory - used for spooling |
TransactionManager |
getTransactionManager()
|
MessageContainerManager |
getTransientQueueContainerManager()
|
MessageContainerManager |
getTransientTopicContainerManager()
|
MessageContainerAdmin[] |
listMessageContainerAdmin()
|
protected java.lang.Class |
loadClass(java.lang.String name,
boolean ignoreErrors)
Tries to load the given class from the current context class loader or class loader which loaded us or return null if the class could not be found |
protected void |
makeDefaultContainerManagers()
|
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
Prepares an XA Transaciton. |
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)
Rollback an XA Transaction. |
void |
rollbackTransaction(BrokerClient client,
java.lang.String transactionId)
rollback a transaction |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
sendToDeadLetterQueue(java.lang.String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
void |
setContainerManagerMap(java.util.Map containerManagerMap)
|
void |
setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
set the dead letter policy |
void |
setMaximumMemoryUsage(long maximumMemoryUsage)
|
void |
setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
set the persistence adaptor |
void |
setPreparedTransactionStore(TransactionStore preparedTransactionStore)
|
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 |
setTempDir(java.io.File tempDir)
|
void |
setTransactionManager(TransactionManager transactionManager)
|
void |
start()
Start this Service |
void |
startTransaction(BrokerClient client,
ActiveMQXid xid)
Starts an XA Transaction. |
void |
startTransaction(BrokerClient client,
java.lang.String transactionId)
Start a transaction. |
void |
stop()
stop this Service |
java.lang.String |
toString()
|
protected PersistenceAdapter |
tryCreatePersistenceAdapter(java.lang.String className,
java.io.File directory,
boolean ignoreErrors)
|
protected void |
validateConsumer(ConsumerInfo info)
Ensures the consumer is valid, throwing a meaningful exception if not |
Methods inherited from class org.activemq.capacity.DelegateCapacityMonitor |
addCapacityEventListener, generateCapacityMonitorEvent, getCurrentCapacity, getCurrentValue, getRoundedCapacity, getRoundingFactor, getValueLimit, removeCapacityEventListener, setCurrentValue, setDelegate, setName, setRoundingFactor, setValueLimit |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.activemq.capacity.CapacityMonitor |
addCapacityEventListener, generateCapacityMonitorEvent, getCurrentCapacity, getCurrentValue, getRoundedCapacity, getRoundingFactor, getValueLimit, removeCapacityEventListener, setCurrentValue, setName, setRoundingFactor, setValueLimit |
Field Detail |
protected static final java.lang.String PROPERTY_STORE_DIRECTORY
protected static final java.lang.String PERSISTENCE_ADAPTER_FACTORY
protected static final java.lang.Class[] NEWINSTANCE_PARAMETER_TYPES
Constructor Detail |
public DefaultBroker(java.lang.String brokerName, java.lang.String brokerClusterName, MemoryBoundedObjectManager memoryManager)
public DefaultBroker(java.lang.String brokerName, MemoryBoundedObjectManager memoryManager)
public DefaultBroker(java.lang.String brokerName, java.lang.String cluserName)
public DefaultBroker(java.lang.String brokerName)
public DefaultBroker(java.lang.String brokerName, java.lang.String brokerClusterName, PersistenceAdapter persistenceAdapter)
public DefaultBroker(java.lang.String brokerName, PersistenceAdapter persistenceAdapter)
Method Detail |
public void start() throws javax.jms.JMSException
start
in interface Service
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface Service
javax.jms.JMSException
public void addClient(BrokerClient client, ConnectionInfo info) throws javax.jms.JMSException
Broker
addClient
in interface Broker
javax.jms.JMSException
public void removeClient(BrokerClient client, ConnectionInfo info) throws javax.jms.JMSException
Broker
removeClient
in interface Broker
javax.jms.JMSException
public void addMessageProducer(BrokerClient client, ProducerInfo info) throws javax.jms.JMSException
Broker
addMessageProducer
in interface Broker
javax.jms.JMSException
public void removeMessageProducer(BrokerClient client, ProducerInfo info) throws javax.jms.JMSException
Broker
removeMessageProducer
in interface Broker
javax.jms.JMSException
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
addMessageConsumer
in interface Broker
javax.jms.JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
removeMessageConsumer
in interface Broker
javax.jms.JMSException
public void sendMessage(BrokerClient client, ActiveMQMessage message) throws javax.jms.JMSException
sendMessage
in interface Broker
javax.jms.JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws javax.jms.JMSException
acknowledgeMessage
in interface Broker
javax.jms.JMSException
public void deleteSubscription(java.lang.String clientId, java.lang.String subscriberName) throws javax.jms.JMSException
Broker
deleteSubscription
in interface Broker
clientId
- subscriberName
-
javax.jms.JMSException
- if the subscriber doesn't exist or is still activepublic void startTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
startTransaction
in interface Broker
client
- transactionId
-
javax.jms.JMSException
Broker.startTransaction(org.activemq.broker.BrokerClient, java.lang.String)
public void commitTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
Broker
commitTransaction
in interface Broker
client
- transactionId
-
javax.jms.JMSException
public void rollbackTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
rollbackTransaction
in interface Broker
client
- transactionId
-
javax.jms.JMSException
public void startTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
startTransaction
in interface Broker
client
- xid
-
javax.transaction.xa.XAException
Broker.startTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public int prepareTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
prepareTransaction
in interface Broker
client
- xid
-
javax.transaction.xa.XAException
Broker.prepareTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public void rollbackTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
rollbackTransaction
in interface Broker
client
- xid
-
javax.transaction.xa.XAException
Broker.rollbackTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public void commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase) throws javax.transaction.xa.XAException
commitTransaction
in interface Broker
client
- xid
- onePhase
-
javax.transaction.xa.XAException
Broker.commitTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid, boolean)
public ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws javax.transaction.xa.XAException
getPreparedTransactions
in interface Broker
client
-
javax.transaction.xa.XAException
Broker.getPreparedTransactions(org.activemq.broker.BrokerClient)
public java.io.File getTempDir()
getTempDir
in interface Broker
public java.lang.String getBrokerName()
getBrokerName
in interface Broker
public java.lang.String getBrokerClusterName()
getBrokerClusterName
in interface Broker
public void setTempDir(java.io.File tempDir)
public MessageContainerManager[] getContainerManagers()
public java.util.Map getContainerManagerMap()
getContainerManagerMap
in interface Broker
public void setContainerManagerMap(java.util.Map containerManagerMap)
public PersistenceAdapter getPersistenceAdapter()
getPersistenceAdapter
in interface Broker
public void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
Broker
setPersistenceAdapter
in interface Broker
persistenceAdapter
- public TransactionManager getTransactionManager()
public void setTransactionManager(TransactionManager transactionManager)
public SecurityAdapter getSecurityAdapter()
Broker
getSecurityAdapter
in interface Broker
public void setSecurityAdapter(SecurityAdapter securityAdapter)
Broker
setSecurityAdapter
in interface Broker
public RedeliveryPolicy getRedeliveryPolicy()
getRedeliveryPolicy
in interface Broker
public void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
Broker
setRedeliveryPolicy
in interface Broker
redeliveryPolicy
- public TransactionStore getPreparedTransactionStore()
public void setPreparedTransactionStore(TransactionStore preparedTransactionStore)
public DeadLetterPolicy getDeadLetterPolicy()
getDeadLetterPolicy
in interface Broker
public void setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
setDeadLetterPolicy
in interface Broker
deadLetterPolicy
- public long getMaximumMemoryUsage()
public void setMaximumMemoryUsage(long maximumMemoryUsage)
maximumMemoryUsage
- The maximumMemoryUsage to set.public javax.naming.Context getDestinationContext(java.util.Hashtable environment)
Broker
getDestinationContext
in interface Broker
environment
-
protected void doMessageSend(BrokerClient client, ActiveMQMessage message) throws javax.jms.JMSException
javax.jms.JMSException
protected PersistenceAdapter createPersistenceAdapter() throws javax.jms.JMSException
javax.jms.JMSException
protected PersistenceAdapter tryCreatePersistenceAdapter(java.lang.String className, java.io.File directory, boolean ignoreErrors) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.JMSException createInstantiateAdapterException(java.lang.String className, java.lang.Throwable e)
protected java.lang.Class loadClass(java.lang.String name, boolean ignoreErrors) throws javax.jms.JMSException
javax.jms.JMSException
protected java.lang.String getStoreDirectory()
protected MessageContainerManager[] createContainerManagers()
protected void makeDefaultContainerManagers()
protected void validateConsumer(ConsumerInfo info) throws javax.jms.JMSException
info
-
javax.jms.JMSException
protected void checkValid() throws javax.jms.JMSException
javax.jms.JMSException
public void addConsumerInfoListener(ConsumerInfoListener l)
addConsumerInfoListener
in interface Broker
l
- public void removeConsumerInfoListener(ConsumerInfoListener l)
removeConsumerInfoListener
in interface Broker
l
- protected void fireConsumerInfo(BrokerClient client, ConsumerInfo info)
public MessageContainerManager getPersistentTopicContainerManager()
getPersistentTopicContainerManager
in interface Broker
public MessageContainerManager getTransientTopicContainerManager()
getTransientTopicContainerManager
in interface Broker
public MessageContainerManager getPersistentQueueContainerManager()
getPersistentQueueContainerManager
in interface Broker
public MessageContainerManager getTransientQueueContainerManager()
getTransientQueueContainerManager
in interface Broker
public BrokerAdmin getBrokerAdmin()
Broker
getBrokerAdmin
in interface Broker
Broker.getBrokerAdmin()
public void createMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
createMessageContainer
in interface BrokerAdmin
javax.jms.JMSException
public void destoryMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
destoryMessageContainer
in interface BrokerAdmin
javax.jms.JMSException
public MessageContainerAdmin getMessageContainerAdmin(ActiveMQDestination dest) throws javax.jms.JMSException
getMessageContainerAdmin
in interface BrokerAdmin
javax.jms.JMSException
public MessageContainerAdmin[] listMessageContainerAdmin() throws javax.jms.JMSException
listMessageContainerAdmin
in interface BrokerAdmin
javax.jms.JMSException
org.activemq.broker.BrokerAdmin#listDestinations()
public void sendToDeadLetterQueue(java.lang.String deadLetterName, ActiveMQMessage message) throws javax.jms.JMSException
sendToDeadLetterQueue
in interface Broker
deadLetterName
- message
-
javax.jms.JMSException
public MemoryBoundedObjectManager getMemoryManager()
public MemoryBoundedQueueManager getQueueManager()
public java.lang.String getName()
CapacityMonitor
getName
in interface CapacityMonitor
getName
in class DelegateCapacityMonitor
public java.lang.String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |