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 void
activated()
Deprecated.void
activationComplete()
Deprecated.void
addAddressSettings(java.lang.String address, org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)
Deprecated.boolean
addConnectionFactoryToBindingRegistry(java.lang.String name, java.lang.String registryBinding)
Deprecated.boolean
addQueueToBindingRegistry(java.lang.String queueName, java.lang.String registryBinding)
Deprecated.void
addSecurity(java.lang.String addressMatch, java.util.Set<org.apache.activemq.artemis.core.security.Role> roles)
Deprecated.boolean
addTopicToBindingRegistry(java.lang.String topicName, java.lang.String registryBinding)
Deprecated.boolean
closeConnectionsForAddress(java.lang.String ipAddress)
Deprecated.boolean
closeConnectionsForUser(java.lang.String userName)
Deprecated.boolean
closeConsumerConnectionsForAddress(java.lang.String address)
Deprecated.void
createConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, java.lang.String... bindings)
Deprecated.void
createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.lang.String discoveryGroupName, java.lang.String... registryBindings)
Deprecated.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)
Deprecated.void
createConnectionFactory(java.lang.String name, boolean ha, JMSFactoryType cfType, java.util.List<java.lang.String> connectorNames, java.lang.String... registryBindings)
Deprecated.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)
Deprecated.boolean
createQueue(boolean storeConfig, java.lang.String queueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings)
Deprecated.Creates a JMS Queue.boolean
createQueue(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.boolean
createTopic(boolean storeConfig, java.lang.String address, boolean autoCreated, java.lang.String... bindings)
Deprecated.boolean
createTopic(boolean storeConfig, java.lang.String address, java.lang.String... bindings)
Deprecated.Creates a JMS Topicboolean
createTopic(boolean storeConfig, java.lang.String address, java.lang.String topicName, boolean autoCreated, java.lang.String... bindings)
Deprecated.boolean
createTopic(java.lang.String address, boolean storeConfig, java.lang.String topicName, java.lang.String... bindings)
Deprecated.Creates a JMS Topicvoid
deActivate()
Deprecated.boolean
destroyConnectionFactory(java.lang.String name)
Deprecated.destroys a connection factory.boolean
destroyQueue(java.lang.String name)
Deprecated.destroys a queue and removes it from the BindingRegistryboolean
destroyQueue(java.lang.String name, boolean removeConsumers)
Deprecated.destroys a queue and removes it from the BindingRegistry.boolean
destroyTopic(java.lang.String name)
Deprecated.destroys a topic and removes it from theBindingRegistryboolean
destroyTopic(java.lang.String name, boolean removeConsumers)
Deprecated.destroys a topic and removes it from the BindingRegistryorg.apache.activemq.artemis.core.server.ActiveMQServer
getActiveMQServer()
Deprecated.org.apache.activemq.artemis.core.settings.impl.AddressSettings
getAddressSettings(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.JMSStorageManager
getJMSStorageManager()
Deprecated.BindingRegistry
getRegistry()
Deprecated.java.util.Set<org.apache.activemq.artemis.core.security.Role>
getSecurity(java.lang.String addressMatch)
Deprecated.java.lang.String
getVersion()
Deprecated.protected ActiveMQConnectionFactory
internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig)
Deprecated.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)
Deprecated.boolean
isStarted()
Deprecated.Has the Server been started.java.lang.String[]
listConnectionIDs()
Deprecated.java.lang.String
listPreparedTransactionDetailsAsHTML()
Deprecated.java.lang.String
listPreparedTransactionDetailsAsJSON()
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.String
listSessionsAsJSON(java.lang.String connectionID)
Deprecated.void
recoverregistryBindings(java.lang.String name, PersistedType type)
Deprecated.ActiveMQConnectionFactory
recreateCF(java.lang.String name, ConnectionFactoryConfiguration cf)
Deprecated.Call this method to have a CF rebound to the Binding Registry and stored on the Journalboolean
removeConnectionFactoryFromBindingRegistry(java.lang.String name)
Deprecated.boolean
removeConnectionFactoryFromBindingRegistry(java.lang.String name, java.lang.String bindings)
Deprecated.boolean
removeQueueFromBindingRegistry(java.lang.String name)
Deprecated.Remove the queue from the BindingRegistry.boolean
removeQueueFromBindingRegistry(java.lang.String name, java.lang.String bindings)
Deprecated.Remove the queue from the BindingRegistry.boolean
removeTopicFromBindingRegistry(java.lang.String name)
Deprecated.Remove the topic from the BindingRegistry.boolean
removeTopicFromBindingRegistry(java.lang.String name, java.lang.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 registryprotected boolean
shutdownConnectionFactory(java.lang.String name)
Deprecated.void
start()
Deprecated.Notice that this component has astartCalled
boolean to control its internal life-cycle, but itsisStarted()
returns the value ofserver.isStarted()
and not the value ofstartCalled
.void
stop()
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.Exception
Deprecated.- Throws:
java.lang.Exception
-
JMSServerManagerImpl
public JMSServerManagerImpl(org.apache.activemq.artemis.core.server.ActiveMQServer server, BindingRegistry registry) throws java.lang.Exception
Deprecated.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.Exception
Deprecated.- Throws:
java.lang.Exception
-
-
Method Detail
-
activated
public void activated()
Deprecated.- Specified by:
activated
in interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
deActivate
public void deActivate()
Deprecated.- Specified by:
deActivate
in interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
activationComplete
public void activationComplete()
Deprecated.- Specified by:
activationComplete
in interfaceorg.apache.activemq.artemis.core.server.ActivateCallback
-
recoverregistryBindings
public void recoverregistryBindings(java.lang.String name, PersistedType type) throws javax.naming.NamingException
Deprecated.- Throws:
javax.naming.NamingException
-
start
public void start() throws java.lang.Exception
Deprecated.Notice that this component has astartCalled
boolean 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:
start
in interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent
- Throws:
java.lang.Exception
-
stop
public void stop() throws java.lang.Exception
Deprecated.- Specified by:
stop
in interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent
- Throws:
java.lang.Exception
-
isStarted
public boolean isStarted()
Deprecated.Description copied from interface:JMSServerManager
Has the Server been started.- Specified by:
isStarted
in interfaceorg.apache.activemq.artemis.core.server.ActiveMQComponent
- Specified by:
isStarted
in interfaceJMSServerManager
- Returns:
- true if the server us running
-
getRegistry
public BindingRegistry getRegistry()
Deprecated.- Specified by:
getRegistry
in interfaceJMSServerManager
-
setRegistry
public void setRegistry(BindingRegistry registry)
Deprecated.Description copied from interface:JMSServerManager
Set this property if you want JMS resources bound to a registry- Specified by:
setRegistry
in interfaceJMSServerManager
-
getActiveMQServer
public org.apache.activemq.artemis.core.server.ActiveMQServer getActiveMQServer()
Deprecated.- Specified by:
getActiveMQServer
in interfaceJMSServerManager
-
addAddressSettings
public void addAddressSettings(java.lang.String address, org.apache.activemq.artemis.core.settings.impl.AddressSettings addressSettings)
Deprecated.- Specified by:
addAddressSettings
in interfaceJMSServerManager
-
getAddressSettings
public org.apache.activemq.artemis.core.settings.impl.AddressSettings getAddressSettings(java.lang.String address)
Deprecated.- Specified by:
getAddressSettings
in interfaceJMSServerManager
-
addSecurity
public void addSecurity(java.lang.String addressMatch, java.util.Set<org.apache.activemq.artemis.core.security.Role> roles)
Deprecated.- Specified by:
addSecurity
in interfaceJMSServerManager
-
getSecurity
public java.util.Set<org.apache.activemq.artemis.core.security.Role> getSecurity(java.lang.String addressMatch)
Deprecated.- Specified by:
getSecurity
in interfaceJMSServerManager
-
getVersion
public java.lang.String getVersion()
Deprecated.- Specified by:
getVersion
in interfaceJMSServerManager
-
createQueue
public boolean createQueue(boolean storeConfig, java.lang.String queueName, java.lang.String selectorString, boolean durable, java.lang.String... bindings) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManager
Creates a JMS Queue.- Specified by:
createQueue
in interfaceJMSServerManager
queueName
- 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.Exception
Deprecated.Description copied from interface:JMSServerManager
Creates a JMS Queue.- Specified by:
createQueue
in interfaceJMSServerManager
queueName
- 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.Exception
Deprecated.- Throws:
java.lang.Exception
-
createTopic
public boolean createTopic(boolean storeConfig, java.lang.String address, java.lang.String... bindings) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManager
Creates a JMS Topic- Specified by:
createTopic
in interfaceJMSServerManager
address
- 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.Exception
Deprecated.Description copied from interface:JMSServerManager
Creates a JMS Topic- Specified by:
createTopic
in 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.Exception
Deprecated.- Specified by:
createTopic
in 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.Exception
Deprecated.- Specified by:
createTopic
in interfaceJMSServerManager
- Returns:
- Throws:
java.lang.Exception
-
addTopicToBindingRegistry
public boolean addTopicToBindingRegistry(java.lang.String topicName, java.lang.String registryBinding) throws java.lang.Exception
Deprecated.- Specified by:
addTopicToBindingRegistry
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
getBindingsOnQueue
public java.lang.String[] getBindingsOnQueue(java.lang.String queue)
Deprecated.- Specified by:
getBindingsOnQueue
in interfaceJMSServerManager
-
getBindingsOnTopic
public java.lang.String[] getBindingsOnTopic(java.lang.String topic)
Deprecated.- Specified by:
getBindingsOnTopic
in interfaceJMSServerManager
-
getBindingsOnConnectionFactory
public java.lang.String[] getBindingsOnConnectionFactory(java.lang.String factoryName)
Deprecated.- Specified by:
getBindingsOnConnectionFactory
in interfaceJMSServerManager
-
addQueueToBindingRegistry
public boolean addQueueToBindingRegistry(java.lang.String queueName, java.lang.String registryBinding) throws java.lang.Exception
Deprecated.- Specified by:
addQueueToBindingRegistry
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
addConnectionFactoryToBindingRegistry
public boolean addConnectionFactoryToBindingRegistry(java.lang.String name, java.lang.String registryBinding) throws java.lang.Exception
Deprecated.- Specified by:
addConnectionFactoryToBindingRegistry
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
removeQueueFromBindingRegistry
public boolean removeQueueFromBindingRegistry(java.lang.String name, java.lang.String bindings) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManager
Remove the queue from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeQueueFromBindingRegistry
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
Remove the queue from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeQueueFromBindingRegistry
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
Remove the topic from the Binding Registry or BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeTopicFromBindingRegistry
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
Remove the topic from the BindingRegistry. Calling this method does not destroy the destination.- Specified by:
removeTopicFromBindingRegistry
in 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.Exception
Deprecated.- Specified by:
removeConnectionFactoryFromBindingRegistry
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
removeConnectionFactoryFromBindingRegistry
public boolean removeConnectionFactoryFromBindingRegistry(java.lang.String name) throws java.lang.Exception
Deprecated.- Specified by:
removeConnectionFactoryFromBindingRegistry
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
destroyQueue
public boolean destroyQueue(java.lang.String name) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManager
destroys a queue and removes it from the BindingRegistry- Specified by:
destroyQueue
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
destroys a queue and removes it from the BindingRegistry. disconnects any consumers connected to the queue.- Specified by:
destroyQueue
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
destroys a topic and removes it from theBindingRegistry- Specified by:
destroyTopic
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
destroys a topic and removes it from the BindingRegistry- Specified by:
destroyTopic
in 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.Exception
Deprecated.- Specified by:
createConnectionFactory
in 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.Exception
Deprecated.- Specified by:
createConnectionFactory
in 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.Exception
Deprecated.- Specified by:
createConnectionFactory
in 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.Exception
Deprecated.- Specified by:
createConnectionFactory
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
recreateCF
public ActiveMQConnectionFactory recreateCF(java.lang.String name, ConnectionFactoryConfiguration cf) throws java.lang.Exception
Deprecated.Description copied from interface:JMSServerManager
Call this method to have a CF rebound to the Binding Registry and stored on the Journal- Specified by:
recreateCF
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
createConnectionFactory
public void createConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, java.lang.String... bindings) throws java.lang.Exception
Deprecated.- Specified by:
createConnectionFactory
in 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.Exception
Deprecated.Description copied from interface:JMSServerManager
destroys a connection factory.- Specified by:
destroyConnectionFactory
in 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.Exception
Deprecated.- Parameters:
name
-- Throws:
java.lang.Exception
-
listRemoteAddresses
public java.lang.String[] listRemoteAddresses() throws java.lang.Exception
Deprecated.- Specified by:
listRemoteAddresses
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listRemoteAddresses
public java.lang.String[] listRemoteAddresses(java.lang.String ipAddress) throws java.lang.Exception
Deprecated.- Specified by:
listRemoteAddresses
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
closeConnectionsForAddress
public boolean closeConnectionsForAddress(java.lang.String ipAddress) throws java.lang.Exception
Deprecated.- Specified by:
closeConnectionsForAddress
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
closeConsumerConnectionsForAddress
public boolean closeConsumerConnectionsForAddress(java.lang.String address) throws java.lang.Exception
Deprecated.- Specified by:
closeConsumerConnectionsForAddress
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
closeConnectionsForUser
public boolean closeConnectionsForUser(java.lang.String userName) throws java.lang.Exception
Deprecated.- Specified by:
closeConnectionsForUser
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listConnectionIDs
public java.lang.String[] listConnectionIDs() throws java.lang.Exception
Deprecated.- Specified by:
listConnectionIDs
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listSessions
public java.lang.String[] listSessions(java.lang.String connectionID) throws java.lang.Exception
Deprecated.- Specified by:
listSessions
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listSessionsAsJSON
public java.lang.String listSessionsAsJSON(java.lang.String connectionID) throws java.lang.Exception
Deprecated.- Specified by:
listSessionsAsJSON
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listPreparedTransactionDetailsAsJSON
public java.lang.String listPreparedTransactionDetailsAsJSON() throws java.lang.Exception
Deprecated.- Specified by:
listPreparedTransactionDetailsAsJSON
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
listPreparedTransactionDetailsAsHTML
@Deprecated public java.lang.String listPreparedTransactionDetailsAsHTML() throws java.lang.Exception
Deprecated.- Specified by:
listPreparedTransactionDetailsAsHTML
in interfaceJMSServerManager
- Throws:
java.lang.Exception
-
-