org.hornetq.jms.management.impl
Class JMSServerControlImpl

java.lang.Object
  javax.management.StandardMBean
      org.hornetq.core.management.impl.AbstractControl
          org.hornetq.jms.management.impl.JMSServerControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, JMSServerControl

public class JMSServerControlImpl
extends org.hornetq.core.management.impl.AbstractControl
implements JMSServerControl, NotificationEmitter

Author:

Jeff Mesnil, Tim Fox

Nested Class Summary

static class

JMSServerControlImpl.NotificationType

Field Summary

Fields inherited from class org.hornetq.core.management.impl.AbstractControl

storageManager

Constructor Summary

JMSServerControlImpl(JMSServerManager server)

Method Summary

void	addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
boolean	closeConnectionsForAddress(String ipAddress)
String	closeConnectionWithClientID(String clientID)
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 jndiBindings) 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 jndiBindings, 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 jndiBindings)
boolean	createQueue(String name, String jndiBindings, String selector)
boolean	createQueue(String name, String jndiBindings, String selector, boolean durable)
boolean	createTopic(String name)
boolean	createTopic(String topicName, String jndiBindings)
void	destroyConnectionFactory(String name)
boolean	destroyQueue(String name)
boolean	destroyTopic(String name)
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String[]	getConnectionFactoryNames()
String	getLastSentMessageID(String sessionID, String address)
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	listPreparedTransactionDetailsAsHTML()
String	listPreparedTransactionDetailsAsJSON()
String[]	listRemoteAddresses()
String[]	listRemoteAddresses(String ipAddress)
String[]	listSessions(String connectionID)
String	listSessionsAsJSON(String connectionID)
String[]	listTargetDestinations(String sessionID)
void	removeNotificationListener(NotificationListener listener)
void	removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)

Methods inherited from class org.hornetq.core.management.impl.AbstractControl

blockOnIO, clearIO, getMBeanInfo

Methods inherited from class javax.management.StandardMBean

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSServerControlImpl

public JMSServerControlImpl(JMSServerManager server)
                     throws Exception

Throws:

Exception

Method Detail

getNotificationInfos

public static MBeanNotificationInfo[] getNotificationInfos()

createConnectionFactory

public void createConnectionFactory(String name,
                                    boolean ha,
                                    boolean useDiscovery,
                                    int cfType,
                                    String[] connectorNames,
                                    Object[] bindings)
                             throws Exception

See the interface definition for the javadoc.

Specified by:

createConnectionFactory in interface JMSServerControl

Throws:

Exception

createConnectionFactory

public void createConnectionFactory(String name,
                                    boolean ha,
                                    boolean useDiscovery,
                                    int cfType,
                                    String connectors,
                                    String jndiBindings,
                                    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

Specified by:

createConnectionFactory in interface JMSServerControl

Throws:

Exception

createConnectionFactory

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

Specified by:

createConnectionFactory in interface JMSServerControl

Throws:

Exception

createConnectionFactory

public void createConnectionFactory(String name,
                                    boolean ha,
                                    boolean useDiscovery,
                                    int cfType,
                                    String connectors,
                                    String jndiBindings)
                             throws Exception

Create a JMS ConnectionFactory with the specified name connected to a single live-backup pair of servers.
The ConnectionFactory is bound to JNDI for all the specified bindings Strings.

Specified by:

createConnectionFactory in interface JMSServerControl

Throws:

Exception

createQueue

public boolean createQueue(String name)
                    throws Exception

Specified by:

createQueue in interface JMSServerControl

Throws:

Exception

createQueue

public boolean createQueue(String name,
                           String jndiBindings)
                    throws Exception

Specified by:

createQueue in interface JMSServerControl

Throws:

Exception

createQueue

public boolean createQueue(String name,
                           String jndiBindings,
                           String selector)
                    throws Exception

Specified by:

createQueue in interface JMSServerControl

Throws:

Exception

createQueue

public boolean createQueue(String name,
                           String jndiBindings,
                           String selector,
                           boolean durable)
                    throws Exception

Specified by:

createQueue in interface JMSServerControl

Throws:

Exception

destroyQueue

public boolean destroyQueue(String name)
                     throws Exception

Specified by:

destroyQueue in interface JMSServerControl

Throws:

Exception

createTopic

public boolean createTopic(String name)
                    throws Exception

Specified by:

createTopic in interface JMSServerControl

Throws:

Exception

createTopic

public boolean createTopic(String topicName,
                           String jndiBindings)
                    throws Exception

Specified by:

createTopic in interface JMSServerControl

Throws:

Exception

destroyTopic

public boolean destroyTopic(String name)
                     throws Exception

Specified by:

destroyTopic in interface JMSServerControl

Throws:

Exception

destroyConnectionFactory

public void destroyConnectionFactory(String name)
                              throws Exception

Specified by:

destroyConnectionFactory in interface JMSServerControl

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface JMSServerControl

getVersion

public String getVersion()

Specified by:

getVersion in interface JMSServerControl

getQueueNames

public String[] getQueueNames()

Specified by:

getQueueNames in interface JMSServerControl

getTopicNames

public String[] getTopicNames()

Specified by:

getTopicNames in interface JMSServerControl

getConnectionFactoryNames

public String[] getConnectionFactoryNames()

Specified by:

getConnectionFactoryNames in interface JMSServerControl

removeNotificationListener

public void removeNotificationListener(NotificationListener listener,
                                       NotificationFilter filter,
                                       Object handback)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationEmitter

Throws:

ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationBroadcaster

Throws:

ListenerNotFoundException

addNotificationListener

public void addNotificationListener(NotificationListener listener,
                                    NotificationFilter filter,
                                    Object handback)
                             throws IllegalArgumentException

Specified by:

addNotificationListener in interface NotificationBroadcaster

Throws:

IllegalArgumentException

getNotificationInfo

public MBeanNotificationInfo[] getNotificationInfo()

Specified by:

getNotificationInfo in interface NotificationBroadcaster

listRemoteAddresses

public String[] listRemoteAddresses()
                             throws Exception

Specified by:

listRemoteAddresses in interface JMSServerControl

Throws:

Exception

listRemoteAddresses

public String[] listRemoteAddresses(String ipAddress)
                             throws Exception

Specified by:

listRemoteAddresses in interface JMSServerControl

Throws:

Exception

closeConnectionsForAddress

public boolean closeConnectionsForAddress(String ipAddress)
                                   throws Exception

Specified by:

closeConnectionsForAddress in interface JMSServerControl

Throws:

Exception

listConnectionIDs

public String[] listConnectionIDs()
                           throws Exception

Specified by:

listConnectionIDs in interface JMSServerControl

Throws:

Exception

listConnectionsAsJSON

public String listConnectionsAsJSON()
                             throws Exception

Specified by:

listConnectionsAsJSON in interface JMSServerControl

Throws:

Exception

listConsumersAsJSON

public String listConsumersAsJSON(String connectionID)
                           throws Exception

Specified by:

listConsumersAsJSON in interface JMSServerControl

Throws:

Exception

listAllConsumersAsJSON

public String listAllConsumersAsJSON()
                              throws Exception

Specified by:

listAllConsumersAsJSON in interface JMSServerControl

Throws:

Exception

listSessions

public String[] listSessions(String connectionID)
                      throws Exception

Specified by:

listSessions in interface JMSServerControl

Throws:

Exception

listPreparedTransactionDetailsAsJSON

public String listPreparedTransactionDetailsAsJSON()
                                            throws Exception

Specified by:

listPreparedTransactionDetailsAsJSON in interface JMSServerControl

Throws:

Exception

listPreparedTransactionDetailsAsHTML

public String listPreparedTransactionDetailsAsHTML()
                                            throws Exception

Specified by:

listPreparedTransactionDetailsAsHTML in interface JMSServerControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class org.hornetq.core.management.impl.AbstractControl

listTargetDestinations

public String[] listTargetDestinations(String sessionID)
                                throws Exception

Specified by:

listTargetDestinations in interface JMSServerControl

Throws:

Exception

getLastSentMessageID

public String getLastSentMessageID(String sessionID,
                                   String address)
                            throws Exception

Specified by:

getLastSentMessageID in interface JMSServerControl

Throws:

Exception

getSessionCreationTime

public String getSessionCreationTime(String sessionID)
                              throws Exception

Specified by:

getSessionCreationTime in interface JMSServerControl

Throws:

Exception

listSessionsAsJSON

public String listSessionsAsJSON(String connectionID)
                          throws Exception

Specified by:

listSessionsAsJSON in interface JMSServerControl

Throws:

Exception

closeConnectionWithClientID

public String closeConnectionWithClientID(String clientID)
                                   throws Exception

Specified by:

closeConnectionWithClientID in interface JMSServerControl

Throws:

Exception