|
|||||||||||
| 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 Servicejavax.jms.JMSException
public void stop()
throws javax.jms.JMSException
stop in interface Servicejavax.jms.JMSException
public void addClient(BrokerClient client,
ConnectionInfo info)
throws javax.jms.JMSException
Broker
addClient in interface Brokerjavax.jms.JMSException
public void removeClient(BrokerClient client,
ConnectionInfo info)
throws javax.jms.JMSException
Broker
removeClient in interface Brokerjavax.jms.JMSException
public void addMessageProducer(BrokerClient client,
ProducerInfo info)
throws javax.jms.JMSException
Broker
addMessageProducer in interface Brokerjavax.jms.JMSException
public void removeMessageProducer(BrokerClient client,
ProducerInfo info)
throws javax.jms.JMSException
Broker
removeMessageProducer in interface Brokerjavax.jms.JMSException
public void addMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
addMessageConsumer in interface Brokerjavax.jms.JMSException
public void removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
removeMessageConsumer in interface Brokerjavax.jms.JMSException
public void sendMessage(BrokerClient client,
ActiveMQMessage message)
throws javax.jms.JMSException
sendMessage in interface Brokerjavax.jms.JMSException
public void acknowledgeMessage(BrokerClient client,
MessageAck ack)
throws javax.jms.JMSException
acknowledgeMessage in interface Brokerjavax.jms.JMSException
public void deleteSubscription(java.lang.String clientId,
java.lang.String subscriberName)
throws javax.jms.JMSException
Broker
deleteSubscription in interface BrokerclientId - subscriberName -
javax.jms.JMSException - if the subscriber doesn't exist or is still active
public void startTransaction(BrokerClient client,
java.lang.String transactionId)
throws javax.jms.JMSException
startTransaction in interface Brokerclient - transactionId -
javax.jms.JMSExceptionBroker.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 Brokerclient - transactionId -
javax.jms.JMSException
public void rollbackTransaction(BrokerClient client,
java.lang.String transactionId)
throws javax.jms.JMSException
rollbackTransaction in interface Brokerclient - transactionId -
javax.jms.JMSException
public void startTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
startTransaction in interface Brokerclient - xid -
javax.transaction.xa.XAExceptionBroker.startTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public int prepareTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
prepareTransaction in interface Brokerclient - xid -
javax.transaction.xa.XAExceptionBroker.prepareTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public void rollbackTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
rollbackTransaction in interface Brokerclient - xid -
javax.transaction.xa.XAExceptionBroker.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 Brokerclient - xid - onePhase -
javax.transaction.xa.XAExceptionBroker.commitTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid, boolean)
public ActiveMQXid[] getPreparedTransactions(BrokerClient client)
throws javax.transaction.xa.XAException
getPreparedTransactions in interface Brokerclient -
javax.transaction.xa.XAExceptionBroker.getPreparedTransactions(org.activemq.broker.BrokerClient)public java.io.File getTempDir()
getTempDir in interface Brokerpublic java.lang.String getBrokerName()
getBrokerName in interface Brokerpublic java.lang.String getBrokerClusterName()
getBrokerClusterName in interface Brokerpublic void setTempDir(java.io.File tempDir)
public MessageContainerManager[] getContainerManagers()
public java.util.Map getContainerManagerMap()
getContainerManagerMap in interface Brokerpublic void setContainerManagerMap(java.util.Map containerManagerMap)
public PersistenceAdapter getPersistenceAdapter()
getPersistenceAdapter in interface Brokerpublic void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
Broker
setPersistenceAdapter in interface BrokerpersistenceAdapter - public TransactionManager getTransactionManager()
public void setTransactionManager(TransactionManager transactionManager)
public SecurityAdapter getSecurityAdapter()
Broker
getSecurityAdapter in interface Brokerpublic void setSecurityAdapter(SecurityAdapter securityAdapter)
Broker
setSecurityAdapter in interface Brokerpublic RedeliveryPolicy getRedeliveryPolicy()
getRedeliveryPolicy in interface Brokerpublic void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
Broker
setRedeliveryPolicy in interface BrokerredeliveryPolicy - public TransactionStore getPreparedTransactionStore()
public void setPreparedTransactionStore(TransactionStore preparedTransactionStore)
public DeadLetterPolicy getDeadLetterPolicy()
getDeadLetterPolicy in interface Brokerpublic void setDeadLetterPolicy(DeadLetterPolicy deadLetterPolicy)
setDeadLetterPolicy in interface BrokerdeadLetterPolicy - 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 Brokerenvironment -
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.JMSExceptionprotected 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.JMSExceptionpublic void addConsumerInfoListener(ConsumerInfoListener l)
addConsumerInfoListener in interface Brokerl - public void removeConsumerInfoListener(ConsumerInfoListener l)
removeConsumerInfoListener in interface Brokerl -
protected void fireConsumerInfo(BrokerClient client,
ConsumerInfo info)
public MessageContainerManager getPersistentTopicContainerManager()
getPersistentTopicContainerManager in interface Brokerpublic MessageContainerManager getTransientTopicContainerManager()
getTransientTopicContainerManager in interface Brokerpublic MessageContainerManager getPersistentQueueContainerManager()
getPersistentQueueContainerManager in interface Brokerpublic MessageContainerManager getTransientQueueContainerManager()
getTransientQueueContainerManager in interface Brokerpublic BrokerAdmin getBrokerAdmin()
Broker
getBrokerAdmin in interface BrokerBroker.getBrokerAdmin()
public void createMessageContainer(ActiveMQDestination dest)
throws javax.jms.JMSException
createMessageContainer in interface BrokerAdminjavax.jms.JMSException
public void destoryMessageContainer(ActiveMQDestination dest)
throws javax.jms.JMSException
destoryMessageContainer in interface BrokerAdminjavax.jms.JMSException
public MessageContainerAdmin getMessageContainerAdmin(ActiveMQDestination dest)
throws javax.jms.JMSException
getMessageContainerAdmin in interface BrokerAdminjavax.jms.JMSException
public MessageContainerAdmin[] listMessageContainerAdmin()
throws javax.jms.JMSException
listMessageContainerAdmin in interface BrokerAdminjavax.jms.JMSExceptionorg.activemq.broker.BrokerAdmin#listDestinations()
public void sendToDeadLetterQueue(java.lang.String deadLetterName,
ActiveMQMessage message)
throws javax.jms.JMSException
sendToDeadLetterQueue in interface BrokerdeadLetterName - message -
javax.jms.JMSExceptionpublic MemoryBoundedObjectManager getMemoryManager()
public MemoryBoundedQueueManager getQueueManager()
public java.lang.String getName()
CapacityMonitor
getName in interface CapacityMonitorgetName in class DelegateCapacityMonitorpublic java.lang.String toString()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||