@Deprecated public class JMSServerManagerImpl extends org.apache.activemq.artemis.core.server.impl.CleaningActivateCallback implements JMSServerManager
JMS Connection Factories and Destinations can be configured either using configuration files or using a JMSConfiguration object.
If configuration files are used, JMS resources are redeployed if the files content is changed. If a JMSConfiguration object is used, the JMS resources can not be redeployed.
| Constructor and Description |
|---|
JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server)
Deprecated.
|
JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
BindingRegistry registry)
Deprecated.
This constructor is used by the Application Server's integration
|
JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
JMSConfiguration configuration)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
activated()
Deprecated.
|
void |
activationComplete()
Deprecated.
|
void |
addAddressSettings(String address,
org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)
Deprecated.
|
boolean |
addConnectionFactoryToBindingRegistry(String name,
String registryBinding)
Deprecated.
|
boolean |
addQueueToBindingRegistry(String queueName,
String registryBinding)
Deprecated.
|
void |
addSecurity(String addressMatch,
Set<org.apache.activemq.artemis.core.security.Role> roles)
Deprecated.
|
boolean |
addTopicToBindingRegistry(String topicName,
String registryBinding)
Deprecated.
|
boolean |
closeConnectionsForAddress(String ipAddress)
Deprecated.
|
boolean |
closeConnectionsForUser(String userName)
Deprecated.
|
boolean |
closeConsumerConnectionsForAddress(String address)
Deprecated.
|
void |
createConnectionFactory(boolean storeConfig,
ConnectionFactoryConfiguration cfConfig,
String... bindings)
Deprecated.
|
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
List<String> connectorNames,
String... registryBindings)
Deprecated.
|
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
List<String> connectorNames,
String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
long callFailoverTimeout,
boolean cacheLargeMessagesClient,
int minLargeMessageSize,
boolean compressLargeMessage,
int consumerWindowSize,
int consumerMaxRate,
int confirmationWindowSize,
int producerWindowSize,
int producerMaxRate,
boolean blockOnAcknowledge,
boolean blockOnDurableSend,
boolean blockOnNonDurableSend,
boolean autoGroup,
boolean preAcknowledge,
String loadBalancingPolicyClassName,
int transactionBatchSize,
int dupsOKBatchSize,
boolean useGlobalPools,
int scheduledThreadPoolMaxSize,
int threadPoolMaxSize,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
boolean failoverOnInitialConnection,
String groupId,
String... registryBindings)
Deprecated.
|
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
String discoveryGroupName,
String... registryBindings)
Deprecated.
|
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
String discoveryGroupName,
String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
long callFailoverTimeout,
boolean cacheLargeMessagesClient,
int minLargeMessageSize,
boolean compressLargeMessages,
int consumerWindowSize,
int consumerMaxRate,
int confirmationWindowSize,
int producerWindowSize,
int producerMaxRate,
boolean blockOnAcknowledge,
boolean blockOnDurableSend,
boolean blockOnNonDurableSend,
boolean autoGroup,
boolean preAcknowledge,
String loadBalancingPolicyClassName,
int transactionBatchSize,
int dupsOKBatchSize,
boolean useGlobalPools,
int scheduledThreadPoolMaxSize,
int threadPoolMaxSize,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
boolean failoverOnInitialConnection,
String groupId,
String... registryBindings)
Deprecated.
|
boolean |
createQueue(boolean storeConfig,
String queueName,
String selectorString,
boolean durable,
String... bindings)
Deprecated.
Creates a JMS Queue.
|
boolean |
createQueue(boolean storeConfig,
String queueName,
String jmsQueueName,
String selectorString,
boolean durable,
String... bindings)
Deprecated.
Creates a JMS Queue.
|
boolean |
createTopic(boolean storeConfig,
String address,
boolean autoCreated,
String... bindings)
Deprecated.
|
boolean |
createTopic(boolean storeConfig,
String address,
String... bindings)
Deprecated.
Creates a JMS Topic
|
boolean |
createTopic(boolean storeConfig,
String address,
String topicName,
boolean autoCreated,
String... bindings)
Deprecated.
|
boolean |
createTopic(String address,
boolean storeConfig,
String topicName,
String... bindings)
Deprecated.
Creates a JMS Topic
|
void |
deActivate()
Deprecated.
|
boolean |
destroyConnectionFactory(String name)
Deprecated.
destroys a connection factory.
|
boolean |
destroyQueue(String name)
Deprecated.
destroys a queue and removes it from the BindingRegistry
|
boolean |
destroyQueue(String name,
boolean removeConsumers)
Deprecated.
destroys a queue and removes it from the BindingRegistry.
|
boolean |
destroyTopic(String name)
Deprecated.
destroys a topic and removes it from theBindingRegistry
|
boolean |
destroyTopic(String name,
boolean removeConsumers)
Deprecated.
destroys a topic and removes it from the BindingRegistry
|
org.apache.activemq.artemis.core.server.ActiveMQServer |
getActiveMQServer()
Deprecated.
|
org.apache.activemq.artemis.core.settings.impl.AddressSettings |
getAddressSettings(String address)
Deprecated.
|
String[] |
getBindingsOnConnectionFactory(String factoryName)
Deprecated.
|
String[] |
getBindingsOnQueue(String queue)
Deprecated.
|
String[] |
getBindingsOnTopic(String topic)
Deprecated.
|
JMSStorageManager |
getJMSStorageManager()
Deprecated.
|
BindingRegistry |
getRegistry()
Deprecated.
|
Set<org.apache.activemq.artemis.core.security.Role> |
getSecurity(String addressMatch)
Deprecated.
|
String |
getVersion()
Deprecated.
|
protected ActiveMQConnectionFactory |
internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig)
Deprecated.
|
protected boolean |
internalCreateJMSQueue(boolean storeConfig,
String queueName,
String jmsQueueName,
String selectorString,
boolean durable,
boolean autoCreated,
String... bindings)
Deprecated.
|
boolean |
isStarted()
Deprecated.
Has the Server been started.
|
String[] |
listConnectionIDs()
Deprecated.
|
String |
listPreparedTransactionDetailsAsHTML()
Deprecated.
|
String |
listPreparedTransactionDetailsAsJSON()
Deprecated.
|
String[] |
listRemoteAddresses()
Deprecated.
|
String[] |
listRemoteAddresses(String ipAddress)
Deprecated.
|
String[] |
listSessions(String connectionID)
Deprecated.
|
String |
listSessionsAsJSON(String connectionID)
Deprecated.
|
void |
recoverregistryBindings(String name,
PersistedType type)
Deprecated.
|
ActiveMQConnectionFactory |
recreateCF(String name,
ConnectionFactoryConfiguration cf)
Deprecated.
Call this method to have a CF rebound to the Binding Registry and stored on the Journal
|
boolean |
removeConnectionFactoryFromBindingRegistry(String name)
Deprecated.
|
boolean |
removeConnectionFactoryFromBindingRegistry(String name,
String bindings)
Deprecated.
|
boolean |
removeQueueFromBindingRegistry(String name)
Deprecated.
Remove the queue from the BindingRegistry.
|
boolean |
removeQueueFromBindingRegistry(String name,
String bindings)
Deprecated.
Remove the queue from the BindingRegistry.
|
boolean |
removeTopicFromBindingRegistry(String name)
Deprecated.
Remove the topic from the BindingRegistry.
|
boolean |
removeTopicFromBindingRegistry(String name,
String bindings)
Deprecated.
Remove the topic from the Binding Registry or BindingRegistry.
|
void |
replaceStorageManager(JMSStorageManager newStorage)
Deprecated.
|
void |
setRegistry(BindingRegistry registry)
Deprecated.
Set this property if you want JMS resources bound to a registry
|
protected boolean |
shutdownConnectionFactory(String name)
Deprecated.
|
void |
start()
Deprecated.
Notice that this component has a
startCalled boolean to control its internal
life-cycle, but its isStarted() returns the value of server.isStarted() and
not the value of startCalled. |
void |
stop()
Deprecated.
|
shutdown, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server)
throws Exception
Exceptionpublic JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
BindingRegistry registry)
throws Exception
server - registry - Exceptionpublic JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
JMSConfiguration configuration)
throws Exception
Exceptionpublic void activated()
activated in interface org.apache.activemq.artemis.core.server.ActivateCallbackpublic void deActivate()
deActivate in interface org.apache.activemq.artemis.core.server.ActivateCallbackpublic void activationComplete()
activationComplete in interface org.apache.activemq.artemis.core.server.ActivateCallbackpublic void recoverregistryBindings(String name, PersistedType type) throws NamingException
NamingExceptionpublic void start()
throws Exception
startCalled boolean to control its internal
life-cycle, but its isStarted() returns the value of server.isStarted() and
not the value of startCalled.
This method and server.start() are interdependent in the following way:
start() is called, it sets start_called=true, and
calls ActiveMQServerImpl.start()
ActiveMQServerImpl.start() will call activated()
activated() checks the value of startCalled, which
must already be true.
start in interface org.apache.activemq.artemis.core.server.ActiveMQComponentExceptionpublic void stop()
throws Exception
stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponentExceptionpublic boolean isStarted()
JMSServerManagerisStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponentisStarted in interface JMSServerManagerpublic BindingRegistry getRegistry()
getRegistry in interface JMSServerManagerpublic void setRegistry(BindingRegistry registry)
JMSServerManagersetRegistry in interface JMSServerManagerpublic org.apache.activemq.artemis.core.server.ActiveMQServer getActiveMQServer()
getActiveMQServer in interface JMSServerManagerpublic void addAddressSettings(String address, org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)
addAddressSettings in interface JMSServerManagerpublic org.apache.activemq.artemis.core.settings.impl.AddressSettings getAddressSettings(String address)
getAddressSettings in interface JMSServerManagerpublic void addSecurity(String addressMatch, Set<org.apache.activemq.artemis.core.security.Role> roles)
addSecurity in interface JMSServerManagerpublic Set<org.apache.activemq.artemis.core.security.Role> getSecurity(String addressMatch)
getSecurity in interface JMSServerManagerpublic String getVersion()
getVersion in interface JMSServerManagerpublic boolean createQueue(boolean storeConfig,
String queueName,
String selectorString,
boolean durable,
String... bindings)
throws Exception
JMSServerManagercreateQueue in interface JMSServerManagerqueueName - The name of the queue to createException - if problems were encountered creating the queue.public boolean createQueue(boolean storeConfig,
String queueName,
String jmsQueueName,
String selectorString,
boolean durable,
String... bindings)
throws Exception
JMSServerManagercreateQueue in interface JMSServerManagerqueueName - The name of the core queue to createjmsQueueName - the name of this JMS queueException - if problems were encountered creating the queue.protected boolean internalCreateJMSQueue(boolean storeConfig,
String queueName,
String jmsQueueName,
String selectorString,
boolean durable,
boolean autoCreated,
String... bindings)
throws Exception
Exceptionpublic boolean createTopic(boolean storeConfig,
String address,
String... bindings)
throws Exception
JMSServerManagercreateTopic in interface JMSServerManageraddress - the core addres of thetopicbindings - the names of the binding for the Binding Registry or BindingRegistryException - if a problem occurred creating the topicpublic boolean createTopic(String address, boolean storeConfig, String topicName, String... bindings) throws Exception
JMSServerManagercreateTopic in interface JMSServerManageraddress - the core addres of thetopictopicName - the name of the topicbindings - the names of the binding for the Binding Registry or BindingRegistryException - if a problem occurred creating the topicpublic boolean createTopic(boolean storeConfig,
String address,
boolean autoCreated,
String... bindings)
throws Exception
createTopic in interface JMSServerManagerExceptionpublic boolean createTopic(boolean storeConfig,
String address,
String topicName,
boolean autoCreated,
String... bindings)
throws Exception
createTopic in interface JMSServerManagerExceptionpublic boolean addTopicToBindingRegistry(String topicName, String registryBinding) throws Exception
addTopicToBindingRegistry in interface JMSServerManagerExceptionpublic String[] getBindingsOnQueue(String queue)
getBindingsOnQueue in interface JMSServerManagerpublic String[] getBindingsOnTopic(String topic)
getBindingsOnTopic in interface JMSServerManagerpublic String[] getBindingsOnConnectionFactory(String factoryName)
getBindingsOnConnectionFactory in interface JMSServerManagerpublic boolean addQueueToBindingRegistry(String queueName, String registryBinding) throws Exception
addQueueToBindingRegistry in interface JMSServerManagerExceptionpublic boolean addConnectionFactoryToBindingRegistry(String name, String registryBinding) throws Exception
addConnectionFactoryToBindingRegistry in interface JMSServerManagerExceptionpublic boolean removeQueueFromBindingRegistry(String name, String bindings) throws Exception
JMSServerManagerremoveQueueFromBindingRegistry in interface JMSServerManagername - the name of the destination to remove from the BindingRegistryException - if a problem occurred removing the destinationpublic boolean removeQueueFromBindingRegistry(String name) throws Exception
JMSServerManagerremoveQueueFromBindingRegistry in interface JMSServerManagername - the name of the destination to remove from the BindingRegistryException - if a problem occurred removing the destinationpublic boolean removeTopicFromBindingRegistry(String name, String bindings) throws Exception
JMSServerManagerremoveTopicFromBindingRegistry in interface JMSServerManagername - the name of the destination to remove from the BindingRegistryException - if a problem occurred removing the destinationpublic boolean removeTopicFromBindingRegistry(String name) throws Exception
JMSServerManagerremoveTopicFromBindingRegistry in interface JMSServerManagername - the name of the destination to remove from the BindingRegistryException - if a problem occurred removing the destinationpublic boolean removeConnectionFactoryFromBindingRegistry(String name, String bindings) throws Exception
removeConnectionFactoryFromBindingRegistry in interface JMSServerManagerExceptionpublic boolean removeConnectionFactoryFromBindingRegistry(String name) throws Exception
removeConnectionFactoryFromBindingRegistry in interface JMSServerManagerExceptionpublic boolean destroyQueue(String name) throws Exception
JMSServerManagerdestroyQueue in interface JMSServerManagername - the name of the queue to destroyException - if a problem occurred destroying the queuepublic boolean destroyQueue(String name, boolean removeConsumers) throws Exception
JMSServerManagerdestroyQueue in interface JMSServerManagername - the name of the queue to destroyException - if a problem occurred destroying the queuepublic boolean destroyTopic(String name) throws Exception
JMSServerManagerdestroyTopic in interface JMSServerManagername - the name of the topic to destroyException - if a problem occurred destroying the topicpublic boolean destroyTopic(String name, boolean removeConsumers) throws Exception
JMSServerManagerdestroyTopic in interface JMSServerManagername - the name of the topic to destroyException - if a problem occurred destroying the topicpublic void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, List<String> connectorNames, String... registryBindings) throws Exception
createConnectionFactory in interface JMSServerManagerExceptionpublic void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, List<String> connectorNames, String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, long callFailoverTimeout, boolean cacheLargeMessagesClient, int minLargeMessageSize, boolean compressLargeMessage, int consumerWindowSize, int consumerMaxRate, int confirmationWindowSize, int producerWindowSize, int producerMaxRate, boolean blockOnAcknowledge, boolean blockOnDurableSend, boolean blockOnNonDurableSend, boolean autoGroup, boolean preAcknowledge, String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, String groupId, String... registryBindings) throws Exception
createConnectionFactory in interface JMSServerManagerExceptionpublic void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, String discoveryGroupName, String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, long callFailoverTimeout, boolean cacheLargeMessagesClient, int minLargeMessageSize, boolean compressLargeMessages, int consumerWindowSize, int consumerMaxRate, int confirmationWindowSize, int producerWindowSize, int producerMaxRate, boolean blockOnAcknowledge, boolean blockOnDurableSend, boolean blockOnNonDurableSend, boolean autoGroup, boolean preAcknowledge, String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, String groupId, String... registryBindings) throws Exception
createConnectionFactory in interface JMSServerManagerExceptionpublic void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, String discoveryGroupName, String... registryBindings) throws Exception
createConnectionFactory in interface JMSServerManagerExceptionpublic ActiveMQConnectionFactory recreateCF(String name, ConnectionFactoryConfiguration cf) throws Exception
JMSServerManagerrecreateCF in interface JMSServerManagerExceptionpublic void createConnectionFactory(boolean storeConfig,
ConnectionFactoryConfiguration cfConfig,
String... bindings)
throws Exception
createConnectionFactory in interface JMSServerManagerExceptionpublic JMSStorageManager getJMSStorageManager()
public void replaceStorageManager(JMSStorageManager newStorage)
protected ActiveMQConnectionFactory internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig) throws ActiveMQException
cfConfig - ActiveMQExceptionpublic boolean destroyConnectionFactory(String name) throws Exception
JMSServerManagerdestroyConnectionFactory in interface JMSServerManagername - the name of the connection factory to destroyException - if a problem occurred destroying the connection factoryprotected boolean shutdownConnectionFactory(String name) throws Exception
name - Exceptionpublic String[] listRemoteAddresses() throws Exception
listRemoteAddresses in interface JMSServerManagerExceptionpublic String[] listRemoteAddresses(String ipAddress) throws Exception
listRemoteAddresses in interface JMSServerManagerExceptionpublic boolean closeConnectionsForAddress(String ipAddress) throws Exception
closeConnectionsForAddress in interface JMSServerManagerExceptionpublic boolean closeConsumerConnectionsForAddress(String address) throws Exception
closeConsumerConnectionsForAddress in interface JMSServerManagerExceptionpublic boolean closeConnectionsForUser(String userName) throws Exception
closeConnectionsForUser in interface JMSServerManagerExceptionpublic String[] listConnectionIDs() throws Exception
listConnectionIDs in interface JMSServerManagerExceptionpublic String[] listSessions(String connectionID) throws Exception
listSessions in interface JMSServerManagerExceptionpublic String listSessionsAsJSON(String connectionID) throws Exception
listSessionsAsJSON in interface JMSServerManagerExceptionpublic String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON in interface JMSServerManagerExceptionpublic String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML in interface JMSServerManagerExceptionCopyright © 2020 The Apache Software Foundation. All rights reserved.