public interface JMSServerManager extends HornetQComponent
Modifier and Type | Method and Description |
---|---|
void |
addAddressSettings(String address,
AddressSettings addressSettings) |
boolean |
addConnectionFactoryToJNDI(String name,
String binding) |
boolean |
addQueueToJndi(String queueName,
String binding) |
void |
addSecurity(String addressMatch,
Set<Role> roles) |
boolean |
addTopicToJndi(String topicName,
String binding) |
boolean |
closeConnectionsForAddress(String ipAddress) |
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,
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... jndiBindings) |
void |
createConnectionFactory(String name,
boolean ha,
JMSFactoryType cfType,
String discoveryGroupName,
String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
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,
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 JNDI or BindingRegistry
|
boolean |
destroyTopic(String name)
destroys a topic and removes it from JNDI or BindingRegistry
|
AddressSettings |
getAddressSettings(String address) |
HornetQServer |
getHornetQServer() |
String[] |
getJNDIOnConnectionFactory(String factoryName) |
String[] |
getJNDIOnQueue(String queue) |
String[] |
getJNDIOnTopic(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) |
HornetQConnectionFactory |
recreateCF(String name,
ConnectionFactoryConfiguration cf)
Call this method to have a CF rebound to JNDI and stored on the Journal
|
boolean |
removeConnectionFactoryFromJNDI(String name) |
boolean |
removeConnectionFactoryFromJNDI(String name,
String binding) |
boolean |
removeQueueFromJNDI(String name)
Remove the queue from JNDI or BindingRegistry.
|
boolean |
removeQueueFromJNDI(String name,
String binding)
Remove the queue from JNDI or BindingRegistry.
|
boolean |
removeTopicFromJNDI(String name)
Remove the topic from JNDI or BindingRegistry.
|
boolean |
removeTopicFromJNDI(String name,
String binding)
Remove the topic from JNDI or BindingRegistry.
|
void |
setContext(Context context) |
void |
setRegistry(BindingRegistry registry)
Set this property if you want something other than JNDI for your registry
|
start, stop
String getVersion()
boolean isStarted()
isStarted
in interface HornetQComponent
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 addTopicToJndi(String topicName, String binding) throws Exception
Exception
boolean addQueueToJndi(String queueName, String binding) throws Exception
Exception
boolean addConnectionFactoryToJNDI(String name, String binding) throws Exception
Exception
boolean createTopic(boolean storeConfig, String topicName, String... bindings) throws Exception
topicName
- the name of the topicbinding
- the name of the binding for JNDI or BindingRegistryException
- if a problem occurred creating the topicboolean removeTopicFromJNDI(String name, String binding) throws Exception
name
- the name of the destination to remove from JNDI or BindingRegistryException
- if a problem occurred removing the destinationboolean removeTopicFromJNDI(String name) throws Exception
name
- the name of the destination to remove from JNDI or BindingRegistryException
- if a problem occurred removing the destinationboolean removeQueueFromJNDI(String name, String binding) throws Exception
name
- the name of the destination to remove from JNDI or BindingRegistryException
- if a problem occurred removing the destinationboolean removeQueueFromJNDI(String name) throws Exception
name
- the name of the destination to remove from JNDI or BindingRegistryException
- if a problem occurred removing the destinationboolean removeConnectionFactoryFromJNDI(String name, String binding) throws Exception
Exception
boolean removeConnectionFactoryFromJNDI(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 destroyTopic(String name) throws Exception
name
- the name of the topic to destroyException
- if a problem occurred destroying the topicHornetQConnectionFactory recreateCF(String name, ConnectionFactoryConfiguration cf) throws Exception
Exception
void createConnectionFactory(String name, boolean ha, JMSFactoryType cfType, String discoveryGroupName, String... jndiBindings) 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, 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, 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
String listPreparedTransactionDetailsAsJSON() throws Exception
Exception
String listPreparedTransactionDetailsAsHTML() throws Exception
Exception
void setContext(Context context)
HornetQServer getHornetQServer()
void addAddressSettings(String address, AddressSettings addressSettings)
AddressSettings getAddressSettings(String address)
BindingRegistry getRegistry()
void setRegistry(BindingRegistry registry)
registry
- Copyright © 2012 JBoss by Red Hat. All Rights Reserved.