public interface JMSServerManager extends ActiveMQComponent
Modifier and Type | Method and Description |
---|---|
void |
addAddressSettings(String address,
AddressSettings addressSettings) |
boolean |
addConnectionFactoryToBindingRegistry(String name,
String binding) |
boolean |
addQueueToBindingRegistry(String queueName,
String binding) |
void |
addSecurity(String addressMatch,
Set<Role> roles) |
boolean |
addTopicToBindingRegistry(String topicName,
String binding) |
boolean |
closeConnectionsForAddress(String ipAddress) |
boolean |
closeConnectionsForUser(String address) |
boolean |
closeConsumerConnectionsForAddress(String address) |
void |
createConnectionFactory(boolean storeConfig,
ConnectionFactoryConfiguration cfConfig,
String... bindings) |
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
List<String> connectorNames,
String... bindings) |
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... bindings) |
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
String discoveryGroupName,
String... bindings) |
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... bindings) |
boolean |
createQueue(boolean storeConfig,
String queueName,
String selectorString,
boolean durable,
String... bindings)
Creates a JMS Queue.
|
boolean |
createTopic(boolean storeConfig,
String topicName,
boolean autoCreated,
String... bindings) |
boolean |
createTopic(boolean storeConfig,
String topicName,
String... bindings)
Creates a JMS Topic
|
boolean |
destroyConnectionFactory(String name)
destroys a connection factory.
|
boolean |
destroyQueue(String name)
destroys a queue and removes it from the BindingRegistry
|
boolean |
destroyQueue(String name,
boolean removeConsumers)
destroys a queue and removes it from the BindingRegistry.
|
boolean |
destroyTopic(String name)
destroys a topic and removes it from theBindingRegistry
|
boolean |
destroyTopic(String name,
boolean removeConsumers)
destroys a topic and removes it from the BindingRegistry
|
ActiveMQServer |
getActiveMQServer() |
AddressSettings |
getAddressSettings(String address) |
String[] |
getBindingsOnConnectionFactory(String factoryName) |
String[] |
getBindingsOnQueue(String queue) |
String[] |
getBindingsOnTopic(String topic) |
BindingRegistry |
getRegistry() |
Set<Role> |
getSecurity(String addressMatch) |
String |
getVersion() |
boolean |
isStarted()
Has the Server been started.
|
String[] |
listConnectionIDs() |
String |
listPreparedTransactionDetailsAsHTML() |
String |
listPreparedTransactionDetailsAsJSON() |
String[] |
listRemoteAddresses() |
String[] |
listRemoteAddresses(String ipAddress) |
String[] |
listSessions(String connectionID) |
String |
listSessionsAsJSON(String connectionID) |
ActiveMQConnectionFactory |
recreateCF(String name,
ConnectionFactoryConfiguration cf)
Call this method to have a CF rebound to the Binding Registry and stored on the Journal
|
boolean |
removeConnectionFactoryFromBindingRegistry(String name) |
boolean |
removeConnectionFactoryFromBindingRegistry(String name,
String binding) |
boolean |
removeQueueFromBindingRegistry(String name)
Remove the queue from the BindingRegistry.
|
boolean |
removeQueueFromBindingRegistry(String name,
String binding)
Remove the queue from the BindingRegistry.
|
boolean |
removeTopicFromBindingRegistry(String name)
Remove the topic from the BindingRegistry.
|
boolean |
removeTopicFromBindingRegistry(String name,
String binding)
Remove the topic from the Binding Registry or BindingRegistry.
|
void |
setRegistry(BindingRegistry registry)
Set this property if you want JMS resources bound to a registry
|
start, stop
String getVersion()
boolean isStarted()
isStarted
in interface ActiveMQComponent
boolean createQueue(boolean storeConfig, String queueName, String selectorString, boolean durable, String... bindings) throws Exception
queueName
- The name of the queue to createselectorString
- durable
- Exception
- if problems were encountered creating the queue.boolean addTopicToBindingRegistry(String topicName, String binding) throws Exception
Exception
boolean addQueueToBindingRegistry(String queueName, String binding) throws Exception
Exception
boolean addConnectionFactoryToBindingRegistry(String name, String binding) throws Exception
Exception
boolean createTopic(boolean storeConfig, String topicName, String... bindings) throws Exception
topicName
- the name of the topicbindings
- the names of the binding for the Binding Registry or BindingRegistryException
- if a problem occurred creating the topicboolean createTopic(boolean storeConfig, String topicName, boolean autoCreated, String... bindings) throws Exception
storeConfig
- topicName
- autoCreated
- bindings
- Exception
boolean removeTopicFromBindingRegistry(String name, String binding) throws Exception
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationboolean removeTopicFromBindingRegistry(String name) throws Exception
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationboolean removeQueueFromBindingRegistry(String name, String binding) throws Exception
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationboolean removeQueueFromBindingRegistry(String name) throws Exception
name
- the name of the destination to remove from the BindingRegistryException
- if a problem occurred removing the destinationboolean removeConnectionFactoryFromBindingRegistry(String name, String binding) throws Exception
Exception
boolean removeConnectionFactoryFromBindingRegistry(String name) throws Exception
Exception
boolean destroyQueue(String name) throws Exception
name
- the name of the queue to destroyException
- if a problem occurred destroying the queueboolean destroyQueue(String name, boolean removeConsumers) throws Exception
name
- the name of the queue to destroyException
- if a problem occurred destroying the queueboolean destroyTopic(String name, boolean removeConsumers) throws Exception
name
- the name of the topic to destroyException
- if a problem occurred destroying the topicboolean destroyTopic(String name) throws Exception
name
- the name of the topic to destroyException
- if a problem occurred destroying the topicActiveMQConnectionFactory recreateCF(String name, ConnectionFactoryConfiguration cf) throws Exception
Exception
void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, String discoveryGroupName, String... bindings) throws Exception
Exception
void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, List<String> connectorNames, String... bindings) throws Exception
Exception
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... bindings) throws Exception
Exception
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... bindings) throws Exception
Exception
void createConnectionFactory(boolean storeConfig, ConnectionFactoryConfiguration cfConfig, String... bindings) throws Exception
Exception
boolean destroyConnectionFactory(String name) throws Exception
name
- the name of the connection factory to destroyException
- if a problem occurred destroying the connection factoryString[] listRemoteAddresses(String ipAddress) throws Exception
Exception
boolean closeConnectionsForAddress(String ipAddress) throws Exception
Exception
boolean closeConsumerConnectionsForAddress(String address) throws Exception
Exception
boolean closeConnectionsForUser(String address) throws Exception
Exception
String listSessionsAsJSON(String connectionID) throws Exception
Exception
String listPreparedTransactionDetailsAsJSON() throws Exception
Exception
String listPreparedTransactionDetailsAsHTML() throws Exception
Exception
ActiveMQServer getActiveMQServer()
void addAddressSettings(String address, AddressSettings addressSettings)
AddressSettings getAddressSettings(String address)
BindingRegistry getRegistry()
void setRegistry(BindingRegistry registry)
registry
- Copyright © 2017 JBoss by Red Hat. All rights reserved.