public class JMSServerControlImpl extends org.apache.activemq.artemis.core.management.impl.AbstractControl implements JMSServerControl, NotificationEmitter, org.apache.activemq.artemis.core.server.management.NotificationListener
| Constructor and Description |
|---|
JMSServerControlImpl(JMSServerManager server) |
| Modifier and Type | Method and Description |
|---|---|
void |
addNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
boolean |
closeConnectionsForAddress(String ipAddress)
Closes all the connections of clients connected to this server which matches the specified IP address.
|
boolean |
closeConnectionsForUser(String userName)
Closes all the connections on this server for sessions using a particular user name.
|
String |
closeConnectionWithClientID(String clientID)
List all the prepared transaction, sorted by date,
oldest first, with details, in HTML format
|
boolean |
closeConsumerConnectionsForAddress(String address)
Closes all the connections on this server for consumers which are consuming from a queue associated with a particular address.
|
void |
createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
int cfType,
String[] connectorNames,
Object[] bindings)
See the interface definition for the javadoc.
|
void |
createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
int cfType,
String[] connectorNames,
String[] bindings,
String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
long callFailoverTimeout,
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) |
void |
createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
int cfType,
String connectors,
String bindings)
Create a JMS ConnectionFactory with the specified name connected to a single live-backup pair of servers.
|
void |
createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
int cfType,
String connectors,
String bindings,
String clientID,
long clientFailureCheckPeriod,
long connectionTTL,
long callTimeout,
long callFailoverTimeout,
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) |
boolean |
createQueue(String name)
Creates a durable JMS Queue.
|
boolean |
createQueue(String name,
String bindings)
Creates a durable JMS Queue with the specified name and JNDI binding.
|
boolean |
createQueue(String name,
String bindings,
String selector)
Creates a durable JMS Queue with the specified name, JNDI binding and selector.
|
boolean |
createQueue(String name,
String bindings,
String selector,
boolean durable)
Creates a JMS Queue with the specified name, durability, selector and JNDI binding.
|
boolean |
createTopic(String name)
Creates a JMS Topic.
|
boolean |
createTopic(String topicName,
String bindings)
Creates a JMS Topic with the specified name and JNDI binding.
|
void |
destroyConnectionFactory(String name) |
boolean |
destroyQueue(String name)
Destroys a JMS Queue with the specified name.
|
boolean |
destroyQueue(String name,
boolean removeConsumers)
Destroys a JMS Queue with the specified name.
|
boolean |
destroyTopic(String name)
Destroys a JMS Topic with the specified name.
|
boolean |
destroyTopic(String name,
boolean removeConsumers)
Destroys a JMS Topic with the specified name.
|
protected MBeanAttributeInfo[] |
fillMBeanAttributeInfo() |
protected MBeanOperationInfo[] |
fillMBeanOperationInfo() |
String[] |
getConnectionFactoryNames()
Returns the names of the JMS connection factories available on this server.
|
String |
getLastSentMessageID(String sessionID,
String address)
Returns the last sent message's ID from the given session to an address.
|
String |
getNodeID()
Returns the server's nodeId
|
MBeanNotificationInfo[] |
getNotificationInfo() |
static MBeanNotificationInfo[] |
getNotificationInfos() |
String[] |
getQueueNames()
Returns the names of the JMS queues available on this server.
|
String |
getSessionCreationTime(String sessionID)
Gets the session's creation time.
|
String[] |
getTopicNames()
Returns the names of the JMS topics available on this server.
|
String |
getVersion()
Returns this server's version
|
boolean |
isStarted()
Returns whether this server is started.
|
String |
listAllConsumersAsJSON()
Lists all the consumers
The returned String is a JSON string containing an array of JMSConsumerInfo objects.
|
String[] |
listConnectionIDs()
Lists all the IDs of the connections connected to this server.
|
String |
listConnectionsAsJSON()
Lists all the connections connected to this server.
|
String |
listConsumersAsJSON(String connectionID)
Lists all the consumers which belongs to the JMS Connection specified by the connectionID.
|
String |
listNetworkTopology() |
String |
listPreparedTransactionDetailsAsHTML()
List all the prepared transaction, sorted by date,
oldest first, with details, in HTML format
|
String |
listPreparedTransactionDetailsAsJSON()
List all the prepared transaction, sorted by date,
oldest first, with details, in text format
|
String[] |
listRemoteAddresses()
Lists the addresses of all the clients connected to this address.
|
String[] |
listRemoteAddresses(String ipAddress)
Lists the addresses of the clients connected to this address which matches the specified IP address.
|
String[] |
listSessions(String connectionID)
Lists all the sessions IDs for the specified connection ID.
|
String |
listSessionsAsJSON(String connectionID)
Lists all the sessions IDs for the specified connection ID.
|
String[] |
listTargetDestinations(String sessionID)
Lists all addresses to which the designated server session has sent messages.
|
void |
onNotification(org.apache.activemq.artemis.core.server.management.Notification notification) |
void |
removeNotificationListener(NotificationListener listener) |
void |
removeNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
blockOnIO, clearIO, getMBeanInfocacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic JMSServerControlImpl(JMSServerManager server) throws Exception
Exceptionpublic static MBeanNotificationInfo[] getNotificationInfos()
public void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String[] connectorNames, Object[] bindings) throws Exception
createConnectionFactory in interface JMSServerControlExceptionpublic void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String connectors, String bindings, String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, long callFailoverTimeout, 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) throws Exception
createConnectionFactory in interface JMSServerControlExceptionpublic void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String[] connectorNames, String[] bindings, String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, long callFailoverTimeout, 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) throws Exception
createConnectionFactory in interface JMSServerControlExceptionpublic void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String connectors, String bindings) throws Exception
createConnectionFactory in interface JMSServerControlExceptionpublic boolean createQueue(String name) throws Exception
JMSServerControlcreateQueue in interface JMSServerControltrue if the queue was created, false elseExceptionpublic boolean createQueue(String name, String bindings) throws Exception
JMSServerControlcreateQueue in interface JMSServerControltrue if the queue was created, false elseExceptionpublic boolean createQueue(String name, String bindings, String selector) throws Exception
JMSServerControlcreateQueue in interface JMSServerControltrue if the queue was created, false elseExceptionpublic boolean createQueue(String name, String bindings, String selector, boolean durable) throws Exception
JMSServerControlcreateQueue in interface JMSServerControltrue if the queue was created, false elseExceptionpublic boolean destroyQueue(String name) throws Exception
JMSServerControldestroyQueue in interface JMSServerControltrue if the queue was destroyed, false elseExceptionpublic boolean destroyQueue(String name, boolean removeConsumers) throws Exception
JMSServerControldestroyQueue in interface JMSServerControltrue if the queue was destroyed, false elseExceptionpublic boolean createTopic(String name) throws Exception
JMSServerControlcreateTopic in interface JMSServerControltrue if the topic was created, false elseExceptionpublic boolean createTopic(String topicName, String bindings) throws Exception
JMSServerControlcreateTopic in interface JMSServerControltrue if the topic was created, false elseExceptionpublic boolean destroyTopic(String name) throws Exception
JMSServerControldestroyTopic in interface JMSServerControltrue if the topic was destroyed, false elseExceptionpublic boolean destroyTopic(String name, boolean removeConsumers) throws Exception
JMSServerControldestroyTopic in interface JMSServerControltrue if the topic was destroyed, false elseExceptionpublic void destroyConnectionFactory(String name) throws Exception
destroyConnectionFactory in interface JMSServerControlExceptionpublic boolean isStarted()
JMSServerControlisStarted in interface JMSServerControlpublic String getVersion()
JMSServerControlgetVersion in interface JMSServerControlpublic String[] getQueueNames()
JMSServerControlgetQueueNames in interface JMSServerControlpublic String[] getTopicNames()
JMSServerControlgetTopicNames in interface JMSServerControlpublic String[] getConnectionFactoryNames()
JMSServerControlgetConnectionFactoryNames in interface JMSServerControlpublic String getNodeID()
JMSServerControlgetNodeID in interface JMSServerControlpublic void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
removeNotificationListener in interface NotificationEmitterListenerNotFoundExceptionpublic void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener in interface NotificationBroadcasterListenerNotFoundExceptionpublic void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException
addNotificationListener in interface NotificationBroadcasterIllegalArgumentExceptionpublic MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo in interface NotificationBroadcasterpublic String[] listRemoteAddresses() throws Exception
JMSServerControllistRemoteAddresses in interface JMSServerControlExceptionpublic String[] listRemoteAddresses(String ipAddress) throws Exception
JMSServerControllistRemoteAddresses in interface JMSServerControlExceptionpublic boolean closeConnectionsForAddress(String ipAddress) throws Exception
JMSServerControlcloseConnectionsForAddress in interface JMSServerControlExceptionpublic boolean closeConsumerConnectionsForAddress(String address) throws Exception
JMSServerControlcloseConsumerConnectionsForAddress in interface JMSServerControlExceptionpublic boolean closeConnectionsForUser(String userName) throws Exception
JMSServerControlcloseConnectionsForUser in interface JMSServerControlExceptionpublic String[] listConnectionIDs() throws Exception
JMSServerControllistConnectionIDs in interface JMSServerControlExceptionpublic String listConnectionsAsJSON() throws Exception
JMSServerControllistConnectionsAsJSON in interface JMSServerControlExceptionJMSConnectionInfo.from(String)public String listConsumersAsJSON(String connectionID) throws Exception
JMSServerControllistConsumersAsJSON in interface JMSServerControlExceptionJMSConsumerInfo.from(String)public String listAllConsumersAsJSON() throws Exception
JMSServerControllistAllConsumersAsJSON in interface JMSServerControlExceptionJMSConsumerInfo.from(String)public String[] listSessions(String connectionID) throws Exception
JMSServerControllistSessions in interface JMSServerControlExceptionpublic String listPreparedTransactionDetailsAsJSON() throws Exception
JMSServerControllistPreparedTransactionDetailsAsJSON in interface JMSServerControlExceptionpublic String listPreparedTransactionDetailsAsHTML() throws Exception
JMSServerControllistPreparedTransactionDetailsAsHTML in interface JMSServerControlExceptionprotected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo in class org.apache.activemq.artemis.core.management.impl.AbstractControlprotected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo in class org.apache.activemq.artemis.core.management.impl.AbstractControlpublic String[] listTargetDestinations(String sessionID) throws Exception
JMSServerControllistTargetDestinations in interface JMSServerControlExceptionpublic String getLastSentMessageID(String sessionID, String address) throws Exception
JMSServerControlgetLastSentMessageID in interface JMSServerControlExceptionpublic String getSessionCreationTime(String sessionID) throws Exception
JMSServerControlgetSessionCreationTime in interface JMSServerControlExceptionpublic String listSessionsAsJSON(String connectionID) throws Exception
JMSServerControllistSessionsAsJSON in interface JMSServerControlExceptionpublic String listNetworkTopology() throws Exception
listNetworkTopology in interface JMSServerControlExceptionpublic String closeConnectionWithClientID(String clientID) throws Exception
JMSServerControlcloseConnectionWithClientID in interface JMSServerControlExceptionpublic void onNotification(org.apache.activemq.artemis.core.server.management.Notification notification)
onNotification in interface org.apache.activemq.artemis.core.server.management.NotificationListenerCopyright © 2018 The Apache Software Foundation. All rights reserved.