@Deprecated public class JMSServerManagerImpl extends Object implements JMSServerManager, ActivateCallback
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(ActiveMQServer server)
Deprecated.
|
JMSServerManagerImpl(ActiveMQServer server,
BindingRegistry registry)
Deprecated.
This constructor is used by the Application Server's integration
|
JMSServerManagerImpl(ActiveMQServer server,
JMSConfiguration configuration)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
activated()
Deprecated.
|
void |
activationComplete()
Deprecated.
|
void |
addAddressSettings(String address,
AddressSettings addressSettings)
Deprecated.
|
boolean |
addConnectionFactoryToBindingRegistry(String name,
String registryBinding)
Deprecated.
|
boolean |
addQueueToBindingRegistry(String queueName,
String registryBinding)
Deprecated.
|
void |
addSecurity(String addressMatch,
Set<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
|
ActiveMQServer |
getActiveMQServer()
Deprecated.
|
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<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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
preActivate
public JMSServerManagerImpl(ActiveMQServer server) throws Exception
Exception
public JMSServerManagerImpl(ActiveMQServer server, BindingRegistry registry) throws Exception
server
- registry
- Exception
public JMSServerManagerImpl(ActiveMQServer server, JMSConfiguration configuration) throws Exception
Exception
public void activated()
activated
in interface ActivateCallback
public void deActivate()
deActivate
in interface ActivateCallback
public void activationComplete()
activationComplete
in interface ActivateCallback
public void recoverregistryBindings(String name, PersistedType type) throws NamingException
NamingException
public 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 ActiveMQComponent
Exception
public void stop() throws Exception
stop
in interface ActiveMQComponent
Exception
public boolean isStarted()
JMSServerManager
isStarted
in interface ActiveMQComponent
isStarted
in interface JMSServerManager
public BindingRegistry getRegistry()
getRegistry
in interface JMSServerManager
public void setRegistry(BindingRegistry registry)
JMSServerManager
setRegistry
in interface JMSServerManager
public ActiveMQServer getActiveMQServer()
getActiveMQServer
in interface JMSServerManager
public void addAddressSettings(String address, AddressSettings addressSettings)
addAddressSettings
in interface JMSServerManager
public AddressSettings getAddressSettings(String address)
getAddressSettings
in interface JMSServerManager
public void addSecurity(String addressMatch, Set<Role> roles)
addSecurity
in interface JMSServerManager
public Set<Role> getSecurity(String addressMatch)
getSecurity
in interface JMSServerManager
public String getVersion()
getVersion
in interface JMSServerManager
public boolean createQueue(boolean storeConfig, String queueName, String selectorString, boolean durable, String... bindings) throws Exception
JMSServerManager
createQueue
in interface JMSServerManager
queueName
- 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
JMSServerManager
createQueue
in interface JMSServerManager
queueName
- 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
Exception
public boolean createTopic(boolean storeConfig, String address, String... bindings) throws Exception
JMSServerManager
createTopic
in interface JMSServerManager
address
- 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
JMSServerManager
createTopic
in interface JMSServerManager
address
- 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 JMSServerManager
Exception
public boolean createTopic(boolean storeConfig, String address, String topicName, boolean autoCreated, String... bindings) throws Exception
createTopic
in interface JMSServerManager
Exception
public boolean addTopicToBindingRegistry(String topicName, String registryBinding) throws Exception
addTopicToBindingRegistry
in interface JMSServerManager
Exception
public String[] getBindingsOnQueue(String queue)
getBindingsOnQueue
in interface JMSServerManager
public String[] getBindingsOnTopic(String topic)
getBindingsOnTopic
in interface JMSServerManager
public String[] getBindingsOnConnectionFactory(String factoryName)
getBindingsOnConnectionFactory
in interface JMSServerManager
public boolean addQueueToBindingRegistry(String queueName, String registryBinding) throws Exception
addQueueToBindingRegistry
in interface JMSServerManager
Exception
public boolean addConnectionFactoryToBindingRegistry(String name, String registryBinding) throws Exception
addConnectionFactoryToBindingRegistry
in interface JMSServerManager
Exception
public boolean removeQueueFromBindingRegistry(String name, String bindings) throws Exception
JMSServerManager
removeQueueFromBindingRegistry
in interface JMSServerManager
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationpublic boolean removeQueueFromBindingRegistry(String name) throws Exception
JMSServerManager
removeQueueFromBindingRegistry
in interface JMSServerManager
name
- 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
JMSServerManager
removeTopicFromBindingRegistry
in interface JMSServerManager
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationpublic boolean removeTopicFromBindingRegistry(String name) throws Exception
JMSServerManager
removeTopicFromBindingRegistry
in interface JMSServerManager
name
- 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 JMSServerManager
Exception
public boolean removeConnectionFactoryFromBindingRegistry(String name) throws Exception
removeConnectionFactoryFromBindingRegistry
in interface JMSServerManager
Exception
public boolean destroyQueue(String name) throws Exception
JMSServerManager
destroyQueue
in interface JMSServerManager
name
- the name of the queue to destroyException
- if a problem occurred destroying the queuepublic boolean destroyQueue(String name, boolean removeConsumers) throws Exception
JMSServerManager
destroyQueue
in interface JMSServerManager
name
- the name of the queue to destroyException
- if a problem occurred destroying the queuepublic boolean destroyTopic(String name) throws Exception
JMSServerManager
destroyTopic
in interface JMSServerManager
name
- the name of the topic to destroyException
- if a problem occurred destroying the topicpublic boolean destroyTopic(String name, boolean removeConsumers) throws Exception
JMSServerManager
destroyTopic
in interface JMSServerManager
name
- 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 JMSServerManager
Exception
public 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 JMSServerManager
Exception
public 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 JMSServerManager
Exception
public void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, String discoveryGroupName, String... registryBindings) throws Exception
createConnectionFactory
in interface JMSServerManager
Exception
public ActiveMQConnectionFactory recreateCF(String name, ConnectionFactoryConfiguration cf) throws Exception
JMSServerManager
recreateCF
in interface JMSServerManager
Exception
public void createConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, String... bindings) throws Exception
createConnectionFactory
in interface JMSServerManager
Exception
public JMSStorageManager getJMSStorageManager()
public void replaceStorageManager(JMSStorageManager newStorage)
protected ActiveMQConnectionFactory internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig) throws ActiveMQException
cfConfig
- ActiveMQException
public boolean destroyConnectionFactory(String name) throws Exception
JMSServerManager
destroyConnectionFactory
in interface JMSServerManager
name
- the name of the connection factory to destroyException
- if a problem occurred destroying the connection factoryprotected boolean shutdownConnectionFactory(String name) throws Exception
name
- Exception
public String[] listRemoteAddresses() throws Exception
listRemoteAddresses
in interface JMSServerManager
Exception
public String[] listRemoteAddresses(String ipAddress) throws Exception
listRemoteAddresses
in interface JMSServerManager
Exception
public boolean closeConnectionsForAddress(String ipAddress) throws Exception
closeConnectionsForAddress
in interface JMSServerManager
Exception
public boolean closeConsumerConnectionsForAddress(String address) throws Exception
closeConsumerConnectionsForAddress
in interface JMSServerManager
Exception
public boolean closeConnectionsForUser(String userName) throws Exception
closeConnectionsForUser
in interface JMSServerManager
Exception
public String[] listConnectionIDs() throws Exception
listConnectionIDs
in interface JMSServerManager
Exception
public String[] listSessions(String connectionID) throws Exception
listSessions
in interface JMSServerManager
Exception
public String listSessionsAsJSON(String connectionID) throws Exception
listSessionsAsJSON
in interface JMSServerManager
Exception
public String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON
in interface JMSServerManager
Exception
public String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML
in interface JMSServerManager
Exception
Copyright © 2019 JBoss by Red Hat. All rights reserved.