public class JMSServerControlImpl extends AbstractControl implements JMSServerControl, NotificationEmitter, NotificationListener
storageManager
Constructor and Description |
---|
JMSServerControlImpl(JMSServerManager server) |
Modifier and Type | Method and Description |
---|---|
void |
addNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
boolean |
closeConnectionsForAddress(String ipAddress) |
boolean |
closeConnectionsForUser(String userName) |
String |
closeConnectionWithClientID(String clientID) |
boolean |
closeConsumerConnectionsForAddress(String 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) |
boolean |
createQueue(String name,
String bindings) |
boolean |
createQueue(String name,
String bindings,
String selector) |
boolean |
createQueue(String name,
String bindings,
String selector,
boolean durable) |
boolean |
createTopic(String name) |
boolean |
createTopic(String topicName,
String bindings) |
void |
destroyConnectionFactory(String name) |
boolean |
destroyQueue(String name) |
boolean |
destroyQueue(String name,
boolean removeConsumers) |
boolean |
destroyTopic(String name) |
boolean |
destroyTopic(String name,
boolean removeConsumers) |
protected MBeanAttributeInfo[] |
fillMBeanAttributeInfo() |
protected MBeanOperationInfo[] |
fillMBeanOperationInfo() |
String[] |
getConnectionFactoryNames() |
String |
getLastSentMessageID(String sessionID,
String address) |
String |
getNodeID() |
MBeanNotificationInfo[] |
getNotificationInfo() |
static MBeanNotificationInfo[] |
getNotificationInfos() |
String[] |
getQueueNames() |
String |
getSessionCreationTime(String sessionID) |
String[] |
getTopicNames() |
String |
getVersion() |
boolean |
isStarted() |
String |
listAllConsumersAsJSON() |
String[] |
listConnectionIDs() |
String |
listConnectionsAsJSON() |
String |
listConsumersAsJSON(String connectionID) |
String |
listNetworkTopology() |
String |
listPreparedTransactionDetailsAsHTML() |
String |
listPreparedTransactionDetailsAsJSON() |
String[] |
listRemoteAddresses() |
String[] |
listRemoteAddresses(String ipAddress) |
String[] |
listSessions(String connectionID) |
String |
listSessionsAsJSON(String connectionID) |
String[] |
listTargetDestinations(String sessionID) |
void |
onNotification(Notification notification) |
void |
removeNotificationListener(NotificationListener listener) |
void |
removeNotificationListener(NotificationListener listener,
NotificationFilter filter,
Object handback) |
blockOnIO, clearIO, getMBeanInfo
cacheMBeanInfo, 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, setImplementation
public JMSServerControlImpl(JMSServerManager server) throws Exception
Exception
public static MBeanNotificationInfo[] getNotificationInfos()
public void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String[] connectorNames, Object[] bindings) throws Exception
createConnectionFactory
in interface JMSServerControl
Exception
public 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 JMSServerControl
Exception
public 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 JMSServerControl
Exception
public void createConnectionFactory(String name, boolean ha, boolean useDiscovery, int cfType, String connectors, String bindings) throws Exception
createConnectionFactory
in interface JMSServerControl
Exception
public boolean createQueue(String name) throws Exception
createQueue
in interface JMSServerControl
Exception
public boolean createQueue(String name, String bindings) throws Exception
createQueue
in interface JMSServerControl
Exception
public boolean createQueue(String name, String bindings, String selector) throws Exception
createQueue
in interface JMSServerControl
Exception
public boolean createQueue(String name, String bindings, String selector, boolean durable) throws Exception
createQueue
in interface JMSServerControl
Exception
public boolean destroyQueue(String name) throws Exception
destroyQueue
in interface JMSServerControl
Exception
public boolean destroyQueue(String name, boolean removeConsumers) throws Exception
destroyQueue
in interface JMSServerControl
Exception
public boolean createTopic(String name) throws Exception
createTopic
in interface JMSServerControl
Exception
public boolean createTopic(String topicName, String bindings) throws Exception
createTopic
in interface JMSServerControl
Exception
public boolean destroyTopic(String name) throws Exception
destroyTopic
in interface JMSServerControl
Exception
public boolean destroyTopic(String name, boolean removeConsumers) throws Exception
destroyTopic
in interface JMSServerControl
Exception
public void destroyConnectionFactory(String name) throws Exception
destroyConnectionFactory
in interface JMSServerControl
Exception
public boolean isStarted()
isStarted
in interface JMSServerControl
public String getVersion()
getVersion
in interface JMSServerControl
public String[] getQueueNames()
getQueueNames
in interface JMSServerControl
public String[] getTopicNames()
getTopicNames
in interface JMSServerControl
public String[] getConnectionFactoryNames()
getConnectionFactoryNames
in interface JMSServerControl
public String getNodeID()
getNodeID
in interface JMSServerControl
public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationEmitter
ListenerNotFoundException
public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationBroadcaster
ListenerNotFoundException
public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException
addNotificationListener
in interface NotificationBroadcaster
IllegalArgumentException
public MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface NotificationBroadcaster
public String[] listRemoteAddresses() throws Exception
listRemoteAddresses
in interface JMSServerControl
Exception
public String[] listRemoteAddresses(String ipAddress) throws Exception
listRemoteAddresses
in interface JMSServerControl
Exception
public boolean closeConnectionsForAddress(String ipAddress) throws Exception
closeConnectionsForAddress
in interface JMSServerControl
Exception
public boolean closeConsumerConnectionsForAddress(String address) throws Exception
closeConsumerConnectionsForAddress
in interface JMSServerControl
Exception
public boolean closeConnectionsForUser(String userName) throws Exception
closeConnectionsForUser
in interface JMSServerControl
Exception
public String[] listConnectionIDs() throws Exception
listConnectionIDs
in interface JMSServerControl
Exception
public String listConnectionsAsJSON() throws Exception
listConnectionsAsJSON
in interface JMSServerControl
Exception
public String listConsumersAsJSON(String connectionID) throws Exception
listConsumersAsJSON
in interface JMSServerControl
Exception
public String listAllConsumersAsJSON() throws Exception
listAllConsumersAsJSON
in interface JMSServerControl
Exception
public String[] listSessions(String connectionID) throws Exception
listSessions
in interface JMSServerControl
Exception
public String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON
in interface JMSServerControl
Exception
public String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML
in interface JMSServerControl
Exception
protected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo
in class AbstractControl
protected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo
in class AbstractControl
public String[] listTargetDestinations(String sessionID) throws Exception
listTargetDestinations
in interface JMSServerControl
Exception
public String getLastSentMessageID(String sessionID, String address) throws Exception
getLastSentMessageID
in interface JMSServerControl
Exception
public String getSessionCreationTime(String sessionID) throws Exception
getSessionCreationTime
in interface JMSServerControl
Exception
public String listSessionsAsJSON(String connectionID) throws Exception
listSessionsAsJSON
in interface JMSServerControl
Exception
public String listNetworkTopology() throws Exception
listNetworkTopology
in interface JMSServerControl
Exception
public String closeConnectionWithClientID(String clientID) throws Exception
closeConnectionWithClientID
in interface JMSServerControl
Exception
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.