public interface JMSServerControl
Modifier and Type | Method and Description |
---|---|
boolean |
closeConnectionsForAddress(java.lang.String ipAddress)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
void |
createConnectionFactory(java.lang.String name,
boolean ha,
boolean useDiscovery,
int cfType,
java.lang.String[] connectorNames,
java.lang.Object[] bindings)
Create a JMS ConnectionFactory with the specified name connected to a static list of live-backup servers.
|
void |
createConnectionFactory(java.lang.String name,
boolean ha,
boolean useDiscovery,
int cfType,
java.lang.String[] connectors,
java.lang.String[] jndiBindings,
java.lang.String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
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) |
void |
createConnectionFactory(java.lang.String name,
boolean ha,
boolean useDiscovery,
int cfType,
java.lang.String connectors,
java.lang.String jndiBindings)
Create a JMS ConnectionFactory with the specified name connected to a single live-backup pair of servers.
|
void |
createConnectionFactory(java.lang.String name,
boolean ha,
boolean useDiscovery,
int cfType,
java.lang.String connectors,
java.lang.String jndiBindings,
java.lang.String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
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) |
boolean |
createQueue(java.lang.String name)
Creates a durable JMS Queue.
|
boolean |
createQueue(java.lang.String name,
java.lang.String jndiBindings)
Creates a durable JMS Queue with the specified name and JNDI binding.
|
boolean |
createQueue(java.lang.String name,
java.lang.String jndiBindings,
java.lang.String selector)
Creates a durable JMS Queue with the specified name, JNDI binding and selector.
|
boolean |
createQueue(java.lang.String name,
java.lang.String jndiBindings,
java.lang.String selector,
boolean durable)
Creates a JMS Queue with the specified name, durability, selector and JNDI binding.
|
boolean |
createTopic(java.lang.String name)
Creates a JMS Topic.
|
boolean |
createTopic(java.lang.String name,
java.lang.String jndiBindings)
Creates a JMS Topic with the specified name and JNDI binding.
|
void |
destroyConnectionFactory(java.lang.String name) |
boolean |
destroyQueue(java.lang.String name)
Destroys a JMS Queue with the specified name.
|
boolean |
destroyTopic(java.lang.String name)
Destroys a JMS Topic with the specified name.
|
java.lang.String[] |
getConnectionFactoryNames()
Returns the names of the JMS connection factories available on this server.
|
java.lang.String |
getLastSentMessageID(java.lang.String sessionID,
java.lang.String address)
Returns the last sent message's ID from the given session to an address.
|
java.lang.String[] |
getQueueNames()
Returns the names of the JMS queues available on this server.
|
java.lang.String |
getSessionCreationTime(java.lang.String sessionID)
Gets the session's creation time.
|
java.lang.String[] |
getTopicNames()
Returns the names of the JMS topics available on this server.
|
java.lang.String |
getVersion()
Returns this server's version
|
boolean |
isStarted()
Returns whether this server is started.
|
java.lang.String |
listAllConsumersAsJSON()
Lists all the consumers
The returned String is a JSON string containing an array of JMSConsumerInfo objects.
|
java.lang.String[] |
listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
java.lang.String |
listConnectionsAsJSON()
Lists all the connections connected to this server.
|
java.lang.String |
listConsumersAsJSON(java.lang.String connectionID)
Lists all the consumers which belongs to the JMS Connection specified by the connectionID.
|
java.lang.String |
listPreparedTransactionDetailsAsHTML()
List all the prepared transaction, sorted by date,
oldest first, with details, in HTML format
|
java.lang.String |
listPreparedTransactionDetailsAsJSON()
List all the prepared transaction, sorted by date,
oldest first, with details, in text format
|
java.lang.String[] |
listRemoteAddresses()
Lists the addresses of all the clients connected to this address.
|
java.lang.String[] |
listRemoteAddresses(java.lang.String ipAddress)
Lists the addresses of the clients connected to this address which matches the specified IP address.
|
java.lang.String[] |
listSessions(java.lang.String connectionID)
Lists all the sessions IDs for the specified connection ID.
|
java.lang.String |
listSessionsAsJSON(java.lang.String connectionID)
Lists all the sessions IDs for the specified connection ID.
|
java.lang.String[] |
listTargetDestinations(java.lang.String sessionID)
Lists all addresses to which the designated server session has sent messages.
|
boolean isStarted()
java.lang.String getVersion()
java.lang.String[] getTopicNames()
java.lang.String[] getQueueNames()
java.lang.String[] getConnectionFactoryNames()
boolean createQueue(java.lang.String name) throws java.lang.Exception
true
if the queue was created, false
elsejava.lang.Exception
boolean createQueue(java.lang.String name, java.lang.String jndiBindings) throws java.lang.Exception
true
if the queue was created, false
elsejava.lang.Exception
boolean createQueue(java.lang.String name, java.lang.String jndiBindings, java.lang.String selector) throws java.lang.Exception
true
if the queue was created, false
elsejava.lang.Exception
boolean createQueue(java.lang.String name, java.lang.String jndiBindings, java.lang.String selector, boolean durable) throws java.lang.Exception
true
if the queue was created, false
elsejava.lang.Exception
boolean destroyQueue(java.lang.String name) throws java.lang.Exception
true
if the queue was destroyed, false
elsejava.lang.Exception
boolean createTopic(java.lang.String name) throws java.lang.Exception
true
if the topic was created, false
elsejava.lang.Exception
boolean createTopic(java.lang.String name, java.lang.String jndiBindings) throws java.lang.Exception
true
if the topic was created, false
elsejava.lang.Exception
boolean destroyTopic(java.lang.String name) throws java.lang.Exception
true
if the topic was destroyed, false
elsejava.lang.Exception
void createConnectionFactory(java.lang.String name, boolean ha, boolean useDiscovery, int cfType, java.lang.String[] connectorNames, java.lang.Object[] bindings) throws java.lang.Exception
liveConnectorsTransportClassNames
are the class names
of the ConnectorFactory
to connect to the live servers
and liveConnectorTransportParams
are Map<String, Object> for the corresponding TransportConfiguration
's parameters.java.lang.Exception
ClientSessionFactory#setStaticConnectors(java.util.List)
void createConnectionFactory(java.lang.String name, boolean ha, boolean useDiscovery, int cfType, java.lang.String connectors, java.lang.String jndiBindings) throws java.lang.Exception
java.lang.Exception
void createConnectionFactory(java.lang.String name, boolean ha, boolean useDiscovery, int cfType, java.lang.String[] connectors, java.lang.String[] jndiBindings, java.lang.String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, 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) throws java.lang.Exception
java.lang.Exception
void createConnectionFactory(java.lang.String name, boolean ha, boolean useDiscovery, int cfType, java.lang.String connectors, java.lang.String jndiBindings, java.lang.String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, 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) throws java.lang.Exception
java.lang.Exception
void destroyConnectionFactory(java.lang.String name) throws java.lang.Exception
java.lang.Exception
java.lang.String[] listRemoteAddresses() throws java.lang.Exception
java.lang.Exception
java.lang.String[] listRemoteAddresses(java.lang.String ipAddress) throws java.lang.Exception
java.lang.Exception
boolean closeConnectionsForAddress(java.lang.String ipAddress) throws java.lang.Exception
java.lang.Exception
java.lang.String[] listConnectionIDs() throws java.lang.Exception
java.lang.Exception
java.lang.String listConnectionsAsJSON() throws java.lang.Exception
java.lang.Exception
JMSConnectionInfo.from(String)
java.lang.String[] listSessions(java.lang.String connectionID) throws java.lang.Exception
java.lang.Exception
java.lang.String listConsumersAsJSON(java.lang.String connectionID) throws java.lang.Exception
java.lang.Exception
JMSConsumerInfo.from(String)
java.lang.String listAllConsumersAsJSON() throws java.lang.Exception
java.lang.Exception
JMSConsumerInfo.from(String)
java.lang.String[] listTargetDestinations(java.lang.String sessionID) throws java.lang.Exception
java.lang.Exception
java.lang.String getLastSentMessageID(java.lang.String sessionID, java.lang.String address) throws java.lang.Exception
java.lang.Exception
java.lang.String getSessionCreationTime(java.lang.String sessionID) throws java.lang.Exception
java.lang.Exception
java.lang.String listSessionsAsJSON(java.lang.String connectionID) throws java.lang.Exception
java.lang.Exception
java.lang.String listPreparedTransactionDetailsAsJSON() throws java.lang.Exception
java.lang.Exception
java.lang.String listPreparedTransactionDetailsAsHTML() throws java.lang.Exception
java.lang.Exception
Copyright © 2009 Red Hat Inc. All Rights Reserved.