Class JMSServerManagerImpl
- java.lang.Object
-
- org.apache.activemq.artemis.core.server.impl.CleaningActivateCallback
-
- org.apache.activemq.artemis.jms.server.impl.JMSServerManagerImpl
-
- All Implemented Interfaces:
org.apache.activemq.artemis.core.server.ActivateCallback,org.apache.activemq.artemis.core.server.ActiveMQComponent,JMSServerManager
@Deprecated public class JMSServerManagerImpl extends org.apache.activemq.artemis.core.server.impl.CleaningActivateCallback implements JMSServerManager
Deprecated.A Deployer used to create and add to Bindings queues, topics and connection factories. Typically this would only be used in an app server env.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 Summary
Constructors Constructor Description JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server)Deprecated.JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server, JMSConfiguration configuration)Deprecated.JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server, BindingRegistry registry)Deprecated.This constructor is used by the Application Server's integration
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidactivated()Deprecated.voidactivationComplete()Deprecated.voidaddAddressSettings(java.lang.String address, org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)Deprecated.booleanaddConnectionFactoryToBindingRegistry(java.lang.String name, java.lang.String registryBinding)Deprecated.booleanaddQueueToBindingRegistry(java.lang.String queueName, java.lang.String registryBinding)Deprecated.voidaddSecurity(java.lang.String addressMatch, java.util.Set<org.apache.activemq.artemis.core.security.Role> roles)Deprecated.booleanaddTopicToBindingRegistry(java.lang.String topicName, java.lang.String registryBinding)Deprecated.booleancloseConnectionsForAddress(java.lang.String ipAddress)Deprecated.booleancloseConnectionsForUser(java.lang.String userName)Deprecated.booleancloseConsumerConnectionsForAddress(java.lang.String address)Deprecated.voidcreateConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, java.lang.String... bindings)Deprecated.voidcreateConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.lang.String discoveryGroupName, java.lang.String... registryBindings)Deprecated.voidcreateConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.lang.String discoveryGroupName, java.lang.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, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, java.lang.String groupId, java.lang.String... registryBindings)Deprecated.voidcreateConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.util.List<java.lang.String> connectorNames, java.lang.String... registryBindings)Deprecated.voidcreateConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.util.List<java.lang.String> connectorNames, java.lang.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, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, java.lang.String groupId, java.lang.String... registryBindings)Deprecated.booleancreateQueue(boolean storeConfig, java.lang.String queueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings)Deprecated.Creates a JMS Queue.booleancreateQueue(boolean storeConfig, java.lang.String queueName, java.lang.String jmsQueueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings)Deprecated.Creates a JMS Queue.booleancreateTopic(boolean storeConfig, java.lang.String address, boolean autoCreated, java.lang.String... bindings)Deprecated.booleancreateTopic(boolean storeConfig, java.lang.String address, java.lang.String... bindings)Deprecated.Creates a JMS TopicbooleancreateTopic(boolean storeConfig, java.lang.String address, java.lang.String topicName, boolean autoCreated, java.lang.String... bindings)Deprecated.booleancreateTopic(java.lang.String address, boolean storeConfig, java.lang.String topicName, java.lang.String... bindings)Deprecated.Creates a JMS TopicvoiddeActivate()Deprecated.booleandestroyConnectionFactory(java.lang.String name)Deprecated.destroys a connection factory.booleandestroyQueue(java.lang.String name)Deprecated.destroys a queue and removes it from the BindingRegistrybooleandestroyQueue(java.lang.String name, boolean removeConsumers)Deprecated.destroys a queue and removes it from the BindingRegistry.booleandestroyTopic(java.lang.String name)Deprecated.destroys a topic and removes it from theBindingRegistrybooleandestroyTopic(java.lang.String name, boolean removeConsumers)Deprecated.destroys a topic and removes it from the BindingRegistryorg.apache.activemq.artemis.core.server.ActiveMQServergetActiveMQServer()Deprecated.org.apache.activemq.artemis.core.settings.impl.AddressSettingsgetAddressSettings(java.lang.String address)Deprecated.java.lang.String[]getBindingsOnConnectionFactory(java.lang.String factoryName)Deprecated.java.lang.String[]getBindingsOnQueue(java.lang.String queue)Deprecated.java.lang.String[]getBindingsOnTopic(java.lang.String topic)Deprecated.JMSStorageManagergetJMSStorageManager()Deprecated.BindingRegistrygetRegistry()Deprecated.java.util.Set<org.apache.activemq.artemis.core.security.Role>getSecurity(java.lang.String addressMatch)Deprecated.java.lang.StringgetVersion()Deprecated.protected ActiveMQConnectionFactoryinternalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig)Deprecated.protected booleaninternalCreateJMSQueue(boolean storeConfig, java.lang.String queueName, java.lang.String jmsQueueName, java.lang.String selectorString, boolean durable, boolean autoCreated, java.lang.String... bindings)Deprecated.booleanisStarted()Deprecated.Has the Server been started.java.lang.String[]listConnectionIDs()Deprecated.java.lang.StringlistPreparedTransactionDetailsAsHTML()Deprecated.java.lang.StringlistPreparedTransactionDetailsAsJSON()Deprecated.java.lang.String[]listRemoteAddresses()Deprecated.java.lang.String[]listRemoteAddresses(java.lang.String ipAddress)Deprecated.java.lang.String[]listSessions(java.lang.String connectionID)Deprecated.java.lang.StringlistSessionsAsJSON(java.lang.String connectionID)Deprecated.voidrecoverregistryBindings(java.lang.String name, PersistedType type)Deprecated.ActiveMQConnectionFactoryrecreateCF(java.lang.String name, ConnectionFactoryConfiguration cf)Deprecated.Call this method to have a CF rebound to the Binding Registry and stored on the JournalbooleanremoveConnectionFactoryFromBindingRegistry(java.lang.String name)Deprecated.booleanremoveConnectionFactoryFromBindingRegistry(java.lang.String name, java.lang.String bindings)Deprecated.booleanremoveQueueFromBindingRegistry(java.lang.String name)Deprecated.Remove the queue from the BindingRegistry.booleanremoveQueueFromBindingRegistry(java.lang.String name, java.lang.String bindings)Deprecated.Remove the queue from the BindingRegistry.booleanremoveTopicFromBindingRegistry(java.lang.String name)Deprecated.Remove the topic from the BindingRegistry.booleanremoveTopicFromBindingRegistry(java.lang.String name, java.lang.String bindings)Deprecated.Remove the topic from the Binding Registry or BindingRegistry.voidreplaceStorageManager(JMSStorageManager newStorage)Deprecated.voidsetRegistry(BindingRegistry registry)Deprecated.Set this property if you want JMS resources bound to a registryprotected booleanshutdownConnectionFactory(java.lang.String name)Deprecated.voidstart()Deprecated.Notice that this component has astartCalledboolean to control its internal life-cycle, but itsisStarted()returns the value ofserver.isStarted()and not the value ofstartCalled.voidstop()Deprecated.-
Methods inherited from class org.apache.activemq.artemis.core.server.impl.CleaningActivateCallback
shutdown, stop
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Constructor Detail
-
JMSServerManagerImpl
public JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server) throws java.lang.ExceptionDeprecated.- Throws:
java.lang.Exception
-
JMSServerManagerImpl
public JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server, BindingRegistry registry) throws java.lang.ExceptionDeprecated.This constructor is used by the Application Server's integration- Parameters:
server-registry-- Throws:
java.lang.Exception
-
JMSServerManagerImpl
public JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server, JMSConfiguration configuration) throws java.lang.ExceptionDeprecated.- Throws:
java.lang.Exception
-
-
Method Detail
-
activated
public void activated()
Deprecated.- Specified by:
activatedin interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
deActivate
public void deActivate()
Deprecated.- Specified by:
deActivatein interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
activationComplete
public void activationComplete()
Deprecated.- Specified by:
activationCompletein interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
recoverregistryBindings
public void recoverregistryBindings(java.lang.String name, PersistedType type) throws javax.naming.NamingExceptionDeprecated.- Throws:
javax.naming.NamingException
-
start
public void start() throws java.lang.ExceptionDeprecated.Notice that this component has astartCalledboolean to control its internal life-cycle, but itsisStarted()returns the value ofserver.isStarted()and not the value ofstartCalled.This method and
server.start()are interdependent in the following way:start()is called, it setsstart_called=true, and callsActiveMQServerImpl.start()ActiveMQServerImpl.start()will callactivated()activated()checks the value ofstartCalled, which must already be true.
- Specified by:
startin interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent- Throws:
java.lang.Exception
-
stop
public void stop() throws java.lang.ExceptionDeprecated.- Specified by:
stopin interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent- Throws:
java.lang.Exception
-
isStarted
public boolean isStarted()
Deprecated.Description copied from interface:JMSServerManagerHas the Server been started.- Specified by:
isStartedin interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent- Specified by:
isStartedin interfaceJMSServerManager- Returns:
- true if the server us running
-
getRegistry
public BindingRegistry getRegistry()
Deprecated.- Specified by:
getRegistryin interfaceJMSServerManager
-
setRegistry
public void setRegistry(BindingRegistry registry)
Deprecated.Description copied from interface:JMSServerManagerSet this property if you want JMS resources bound to a registry- Specified by:
setRegistryin interfaceJMSServerManager
-
getActiveMQServer
public org.apache.activemq.artemis.core.server.ActiveMQServer getActiveMQServer()
Deprecated.- Specified by:
getActiveMQServerin interfaceJMSServerManager
-
addAddressSettings
public void addAddressSettings(java.lang.String address, org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)Deprecated.- Specified by:
addAddressSettingsin interfaceJMSServerManager
-
getAddressSettings
public org.apache.activemq.artemis.core.settings.impl.AddressSettings getAddressSettings(java.lang.String address)
Deprecated.- Specified by:
getAddressSettingsin interfaceJMSServerManager
-
addSecurity
public void addSecurity(java.lang.String addressMatch, java.util.Set<org.apache.activemq.artemis.core.security.Role> roles)Deprecated.- Specified by:
addSecurityin interfaceJMSServerManager
-
getSecurity
public java.util.Set<org.apache.activemq.artemis.core.security.Role> getSecurity(java.lang.String addressMatch)
Deprecated.- Specified by:
getSecurityin interfaceJMSServerManager
-
getVersion
public java.lang.String getVersion()
Deprecated.- Specified by:
getVersionin interfaceJMSServerManager
-
createQueue
public boolean createQueue(boolean storeConfig, java.lang.String queueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerCreates a JMS Queue.- Specified by:
createQueuein interfaceJMSServerManagerqueueName- The name of the queue to create- Returns:
- true if the queue is created or if it existed and was added to the Binding Registry
- Throws:
java.lang.Exception- if problems were encountered creating the queue.
-
createQueue
public boolean createQueue(boolean storeConfig, java.lang.String queueName, java.lang.String jmsQueueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerCreates a JMS Queue.- Specified by:
createQueuein interfaceJMSServerManagerqueueName- The name of the core queue to createjmsQueueName- the name of this JMS queue- Returns:
- true if the queue is created or if it existed and was added to the Binding Registry
- Throws:
java.lang.Exception- if problems were encountered creating the queue.
-
internalCreateJMSQueue
protected boolean internalCreateJMSQueue(boolean storeConfig, java.lang.String queueName, java.lang.String jmsQueueName, java.lang.String selectorString, boolean durable, boolean autoCreated, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.- Throws:
java.lang.Exception
-
createTopic
public boolean createTopic(boolean storeConfig, java.lang.String address, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerCreates a JMS Topic- Specified by:
createTopicin interfaceJMSServerManageraddress- the core addres of thetopicbindings- the names of the binding for the Binding Registry or BindingRegistry- Returns:
- true if the topic was created or if it existed and was added to the Binding Registry
- Throws:
java.lang.Exception- if a problem occurred creating the topic
-
createTopic
public boolean createTopic(java.lang.String address, boolean storeConfig, java.lang.String topicName, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerCreates a JMS Topic- Specified by:
createTopicin interfaceJMSServerManager- Parameters:
address- the core addres of thetopictopicName- the name of the topicbindings- the names of the binding for the Binding Registry or BindingRegistry- Returns:
- true if the topic was created or if it existed and was added to the Binding Registry
- Throws:
java.lang.Exception- if a problem occurred creating the topic
-
createTopic
public boolean createTopic(boolean storeConfig, java.lang.String address, boolean autoCreated, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.- Specified by:
createTopicin interfaceJMSServerManager- Returns:
- Throws:
java.lang.Exception
-
createTopic
public boolean createTopic(boolean storeConfig, java.lang.String address, java.lang.String topicName, boolean autoCreated, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.- Specified by:
createTopicin interfaceJMSServerManager- Returns:
- Throws:
java.lang.Exception
-
addTopicToBindingRegistry
public boolean addTopicToBindingRegistry(java.lang.String topicName, java.lang.String registryBinding) throws java.lang.ExceptionDeprecated.- Specified by:
addTopicToBindingRegistryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
getBindingsOnQueue
public java.lang.String[] getBindingsOnQueue(java.lang.String queue)
Deprecated.- Specified by:
getBindingsOnQueuein interfaceJMSServerManager
-
getBindingsOnTopic
public java.lang.String[] getBindingsOnTopic(java.lang.String topic)
Deprecated.- Specified by:
getBindingsOnTopicin interfaceJMSServerManager
-
getBindingsOnConnectionFactory
public java.lang.String[] getBindingsOnConnectionFactory(java.lang.String factoryName)
Deprecated.- Specified by:
getBindingsOnConnectionFactoryin interfaceJMSServerManager
-
addQueueToBindingRegistry
public boolean addQueueToBindingRegistry(java.lang.String queueName, java.lang.String registryBinding) throws java.lang.ExceptionDeprecated.- Specified by:
addQueueToBindingRegistryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
addConnectionFactoryToBindingRegistry
public boolean addConnectionFactoryToBindingRegistry(java.lang.String name, java.lang.String registryBinding) throws java.lang.ExceptionDeprecated.- Specified by:
addConnectionFactoryToBindingRegistryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
removeQueueFromBindingRegistry
public boolean removeQueueFromBindingRegistry(java.lang.String name, java.lang.String bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerRemove the queue from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeQueueFromBindingRegistryin interfaceJMSServerManager- Parameters:
name- the name of the destination to remove from the BindingRegistry- Returns:
- true if removed
- Throws:
java.lang.Exception- if a problem occurred removing the destination
-
removeQueueFromBindingRegistry
public boolean removeQueueFromBindingRegistry(java.lang.String name) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerRemove the queue from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeQueueFromBindingRegistryin interfaceJMSServerManager- Parameters:
name- the name of the destination to remove from the BindingRegistry- Returns:
- true if removed
- Throws:
java.lang.Exception- if a problem occurred removing the destination
-
removeTopicFromBindingRegistry
public boolean removeTopicFromBindingRegistry(java.lang.String name, java.lang.String bindings) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerRemove the topic from the Binding Registry or BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeTopicFromBindingRegistryin interfaceJMSServerManager- Parameters:
name- the name of the destination to remove from the BindingRegistry- Returns:
- true if removed
- Throws:
java.lang.Exception- if a problem occurred removing the destination
-
removeTopicFromBindingRegistry
public boolean removeTopicFromBindingRegistry(java.lang.String name) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerRemove the topic from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeTopicFromBindingRegistryin interfaceJMSServerManager- Parameters:
name- the name of the destination to remove from the BindingRegistry- Returns:
- true if removed
- Throws:
java.lang.Exception- if a problem occurred removing the destination
-
removeConnectionFactoryFromBindingRegistry
public boolean removeConnectionFactoryFromBindingRegistry(java.lang.String name, java.lang.String bindings) throws java.lang.ExceptionDeprecated.- Specified by:
removeConnectionFactoryFromBindingRegistryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
removeConnectionFactoryFromBindingRegistry
public boolean removeConnectionFactoryFromBindingRegistry(java.lang.String name) throws java.lang.ExceptionDeprecated.- Specified by:
removeConnectionFactoryFromBindingRegistryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
destroyQueue
public boolean destroyQueue(java.lang.String name) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerdestroys a queue and removes it from the BindingRegistry- Specified by:
destroyQueuein interfaceJMSServerManager- Parameters:
name- the name of the queue to destroy- Returns:
- true if destroyed
- Throws:
java.lang.Exception- if a problem occurred destroying the queue
-
destroyQueue
public boolean destroyQueue(java.lang.String name, boolean removeConsumers) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerdestroys a queue and removes it from the BindingRegistry. disconnects any consumers connected to the queue.- Specified by:
destroyQueuein interfaceJMSServerManager- Parameters:
name- the name of the queue to destroy- Returns:
- true if destroyed
- Throws:
java.lang.Exception- if a problem occurred destroying the queue
-
destroyTopic
public boolean destroyTopic(java.lang.String name) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerdestroys a topic and removes it from theBindingRegistry- Specified by:
destroyTopicin interfaceJMSServerManager- Parameters:
name- the name of the topic to destroy- Returns:
- true if the topic was destroyed
- Throws:
java.lang.Exception- if a problem occurred destroying the topic
-
destroyTopic
public boolean destroyTopic(java.lang.String name, boolean removeConsumers) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerdestroys a topic and removes it from the BindingRegistry- Specified by:
destroyTopicin interfaceJMSServerManager- Parameters:
name- the name of the topic to destroy- Returns:
- true if the topic was destroyed
- Throws:
java.lang.Exception- if a problem occurred destroying the topic
-
createConnectionFactory
public void createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.util.List<java.lang.String> connectorNames, java.lang.String... registryBindings) throws java.lang.ExceptionDeprecated.- Specified by:
createConnectionFactoryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
createConnectionFactory
public void createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.util.List<java.lang.String> connectorNames, java.lang.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, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, java.lang.String groupId, java.lang.String... registryBindings) throws java.lang.ExceptionDeprecated.- Specified by:
createConnectionFactoryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
createConnectionFactory
public void createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.lang.String discoveryGroupName, java.lang.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, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int reconnectAttempts, boolean failoverOnInitialConnection, java.lang.String groupId, java.lang.String... registryBindings) throws java.lang.ExceptionDeprecated.- Specified by:
createConnectionFactoryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
createConnectionFactory
public void createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.lang.String discoveryGroupName, java.lang.String... registryBindings) throws java.lang.ExceptionDeprecated.- Specified by:
createConnectionFactoryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
recreateCF
public ActiveMQConnectionFactory recreateCF(java.lang.String name, ConnectionFactoryConfiguration cf) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManagerCall this method to have a CF rebound to the Binding Registry and stored on the Journal- Specified by:
recreateCFin interfaceJMSServerManager- Throws:
java.lang.Exception
-
createConnectionFactory
public void createConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, java.lang.String... bindings) throws java.lang.ExceptionDeprecated.- Specified by:
createConnectionFactoryin interfaceJMSServerManager- Throws:
java.lang.Exception
-
getJMSStorageManager
public JMSStorageManager getJMSStorageManager()
Deprecated.
-
replaceStorageManager
public void replaceStorageManager(JMSStorageManager newStorage)
Deprecated.
-
internalCreateCFPOJO
protected ActiveMQConnectionFactory internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig) throws org.apache.activemq.artemis.api.core.ActiveMQException
Deprecated.- Parameters:
cfConfig-- Returns:
- Throws:
org.apache.activemq.artemis.api.core.ActiveMQException
-
destroyConnectionFactory
public boolean destroyConnectionFactory(java.lang.String name) throws java.lang.ExceptionDeprecated.Description copied from interface:JMSServerManagerdestroys a connection factory.- Specified by:
destroyConnectionFactoryin interfaceJMSServerManager- Parameters:
name- the name of the connection factory to destroy- Returns:
- true if the connection factory was destroyed
- Throws:
java.lang.Exception- if a problem occurred destroying the connection factory
-
shutdownConnectionFactory
protected boolean shutdownConnectionFactory(java.lang.String name) throws java.lang.ExceptionDeprecated.- Parameters:
name-- Throws:
java.lang.Exception
-
listRemoteAddresses
public java.lang.String[] listRemoteAddresses() throws java.lang.ExceptionDeprecated.- Specified by:
listRemoteAddressesin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listRemoteAddresses
public java.lang.String[] listRemoteAddresses(java.lang.String ipAddress) throws java.lang.ExceptionDeprecated.- Specified by:
listRemoteAddressesin interfaceJMSServerManager- Throws:
java.lang.Exception
-
closeConnectionsForAddress
public boolean closeConnectionsForAddress(java.lang.String ipAddress) throws java.lang.ExceptionDeprecated.- Specified by:
closeConnectionsForAddressin interfaceJMSServerManager- Throws:
java.lang.Exception
-
closeConsumerConnectionsForAddress
public boolean closeConsumerConnectionsForAddress(java.lang.String address) throws java.lang.ExceptionDeprecated.- Specified by:
closeConsumerConnectionsForAddressin interfaceJMSServerManager- Throws:
java.lang.Exception
-
closeConnectionsForUser
public boolean closeConnectionsForUser(java.lang.String userName) throws java.lang.ExceptionDeprecated.- Specified by:
closeConnectionsForUserin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listConnectionIDs
public java.lang.String[] listConnectionIDs() throws java.lang.ExceptionDeprecated.- Specified by:
listConnectionIDsin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listSessions
public java.lang.String[] listSessions(java.lang.String connectionID) throws java.lang.ExceptionDeprecated.- Specified by:
listSessionsin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listSessionsAsJSON
public java.lang.String listSessionsAsJSON(java.lang.String connectionID) throws java.lang.ExceptionDeprecated.- Specified by:
listSessionsAsJSONin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listPreparedTransactionDetailsAsJSON
public java.lang.String listPreparedTransactionDetailsAsJSON() throws java.lang.ExceptionDeprecated.- Specified by:
listPreparedTransactionDetailsAsJSONin interfaceJMSServerManager- Throws:
java.lang.Exception
-
listPreparedTransactionDetailsAsHTML
@Deprecated public java.lang.String listPreparedTransactionDetailsAsHTML() throws java.lang.ExceptionDeprecated.- Specified by:
listPreparedTransactionDetailsAsHTMLin interfaceJMSServerManager- Throws:
java.lang.Exception
-
-