org.jboss.messaging.jms.server.management.impl
Class JMSServerControlImpl

java.lang.Object
  extended by org.jboss.messaging.jms.server.management.impl.JMSServerControlImpl
All Implemented Interfaces:
javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, JMSServerControl

public class JMSServerControlImpl
extends java.lang.Object
implements JMSServerControl, javax.management.NotificationEmitter

Version:
$Revision$
Author:
Jeff Mesnil, Tim Fox

Nested Class Summary
static class JMSServerControlImpl.NotificationType
           
 
Constructor Summary
JMSServerControlImpl(JMSServerManager server)
           
 
Method Summary
 void addNotificationListener(javax.management.NotificationListener listener, javax.management.NotificationFilter filter, java.lang.Object handback)
           
 boolean closeConnectionsForAddress(java.lang.String ipAddress)
           
 void createConnectionFactory(java.lang.String name, java.lang.Object[] liveConnectorsTransportClassNames, java.lang.Object[] liveConnectorTransportParams, java.lang.Object[] backupConnectorsTransportClassNames, java.lang.Object[] backupConnectorTransportParams, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.Object[] liveConnectorsTransportClassNames, java.lang.Object[] liveConnectorTransportParams, java.lang.Object[] backupConnectorsTransportClassNames, java.lang.Object[] backupConnectorTransportParams, java.lang.String clientID, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, int maxConnections, int minLargeMessageSize, int consumerWindowSize, int consumerMaxRate, int producerWindowSize, int producerMaxRate, boolean blockOnAcknowledge, boolean blockOnPersistentSend, boolean blockOnNonPersistentSend, boolean autoGroup, boolean preAcknowledge, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, int reconnectAttempts, boolean failoverOnServerShutdown, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.Object[] liveConnectorsTransportClassNames, java.lang.Object[] liveConnectorTransportParams, java.lang.Object[] backupConnectorsTransportClassNames, java.lang.Object[] backupConnectorTransportParams, java.lang.String clientID, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String discoveryAddress, int discoveryPort, java.lang.String clientID, long discoveryRefreshTimeout, long clientFailureCheckPeriod, long connectionTTL, long callTimeout, int maxConnections, int minLargeMessageSize, int consumerWindowSize, int consumerMaxRate, int producerWindowSize, int producerMaxRate, boolean blockOnAcknowledge, boolean blockOnPersistentSend, boolean blockOnNonPersistentSend, boolean autoGroup, boolean preAcknowledge, java.lang.String loadBalancingPolicyClassName, int transactionBatchSize, int dupsOKBatchSize, long initialWaitTimeout, boolean useGlobalPools, int scheduledThreadPoolMaxSize, int threadPoolMaxSize, long retryInterval, double retryIntervalMultiplier, int reconnectAttempts, boolean failoverOnServerShutdown, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String discoveryAddress, int discoveryPort, java.lang.String clientID, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.util.Map<java.lang.String,java.lang.Object> liveTransportParams, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.util.Map<java.lang.String,java.lang.Object> liveTransportParams, java.lang.String backupTransportClassName, java.util.Map<java.lang.String,java.lang.Object> backupTransportParams, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.util.Map<java.lang.String,java.lang.Object> liveTransportParams, java.lang.String backupTransportClassName, java.util.Map<java.lang.String,java.lang.Object> backupTransportParams, java.lang.String clientID, java.lang.Object[] jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.util.Map<java.lang.String,java.lang.Object> liveTransportParams, java.lang.String clientID, java.lang.Object[] jndiBindings)
           
 boolean createQueue(java.lang.String name, java.lang.String jndiBinding)
           
 boolean createTopic(java.lang.String topicName, java.lang.String jndiBinding)
           
 void destroyConnectionFactory(java.lang.String name)
           
 boolean destroyQueue(java.lang.String name)
           
 boolean destroyTopic(java.lang.String name)
           
 javax.management.MBeanNotificationInfo[] getNotificationInfo()
           
 java.lang.String getVersion()
           
 boolean isStarted()
           
 java.lang.String[] listConnectionIDs()
           
 java.lang.String[] listRemoteAddresses()
           
 java.lang.String[] listRemoteAddresses(java.lang.String ipAddress)
           
 java.lang.String[] listSessions(java.lang.String connectionID)
           
 void removeNotificationListener(javax.management.NotificationListener listener)
           
 void removeNotificationListener(javax.management.NotificationListener listener, javax.management.NotificationFilter filter, java.lang.Object handback)
           
 
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)
Method Detail

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.Object[] liveConnectorsTransportClassNames,
                                    java.lang.Object[] liveConnectorTransportParams,
                                    java.lang.Object[] backupConnectorsTransportClassNames,
                                    java.lang.Object[] backupConnectorTransportParams,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.Object[] liveConnectorsTransportClassNames,
                                    java.lang.Object[] liveConnectorTransportParams,
                                    java.lang.Object[] backupConnectorsTransportClassNames,
                                    java.lang.Object[] backupConnectorTransportParams,
                                    java.lang.String clientID,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.Object[] liveConnectorsTransportClassNames,
                                    java.lang.Object[] liveConnectorTransportParams,
                                    java.lang.Object[] backupConnectorsTransportClassNames,
                                    java.lang.Object[] backupConnectorTransportParams,
                                    java.lang.String clientID,
                                    long clientFailureCheckPeriod,
                                    long connectionTTL,
                                    long callTimeout,
                                    int maxConnections,
                                    int minLargeMessageSize,
                                    int consumerWindowSize,
                                    int consumerMaxRate,
                                    int producerWindowSize,
                                    int producerMaxRate,
                                    boolean blockOnAcknowledge,
                                    boolean blockOnPersistentSend,
                                    boolean blockOnNonPersistentSend,
                                    boolean autoGroup,
                                    boolean preAcknowledge,
                                    java.lang.String loadBalancingPolicyClassName,
                                    int transactionBatchSize,
                                    int dupsOKBatchSize,
                                    boolean useGlobalPools,
                                    int scheduledThreadPoolMaxSize,
                                    int threadPoolMaxSize,
                                    long retryInterval,
                                    double retryIntervalMultiplier,
                                    int reconnectAttempts,
                                    boolean failoverOnServerShutdown,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String discoveryAddress,
                                    int discoveryPort,
                                    java.lang.String clientID,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String discoveryAddress,
                                    int discoveryPort,
                                    java.lang.String clientID,
                                    long discoveryRefreshTimeout,
                                    long clientFailureCheckPeriod,
                                    long connectionTTL,
                                    long callTimeout,
                                    int maxConnections,
                                    int minLargeMessageSize,
                                    int consumerWindowSize,
                                    int consumerMaxRate,
                                    int producerWindowSize,
                                    int producerMaxRate,
                                    boolean blockOnAcknowledge,
                                    boolean blockOnPersistentSend,
                                    boolean blockOnNonPersistentSend,
                                    boolean autoGroup,
                                    boolean preAcknowledge,
                                    java.lang.String loadBalancingPolicyClassName,
                                    int transactionBatchSize,
                                    int dupsOKBatchSize,
                                    long initialWaitTimeout,
                                    boolean useGlobalPools,
                                    int scheduledThreadPoolMaxSize,
                                    int threadPoolMaxSize,
                                    long retryInterval,
                                    double retryIntervalMultiplier,
                                    int reconnectAttempts,
                                    boolean failoverOnServerShutdown,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String liveTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> liveTransportParams,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String liveTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> liveTransportParams,
                                    java.lang.String clientID,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String liveTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> liveTransportParams,
                                    java.lang.String backupTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> backupTransportParams,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String liveTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> liveTransportParams,
                                    java.lang.String backupTransportClassName,
                                    java.util.Map<java.lang.String,java.lang.Object> backupTransportParams,
                                    java.lang.String clientID,
                                    java.lang.Object[] jndiBindings)
                             throws java.lang.Exception
Specified by:
createConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

createQueue

public boolean createQueue(java.lang.String name,
                           java.lang.String jndiBinding)
                    throws java.lang.Exception
Specified by:
createQueue in interface JMSServerControl
Throws:
java.lang.Exception

destroyQueue

public boolean destroyQueue(java.lang.String name)
                     throws java.lang.Exception
Specified by:
destroyQueue in interface JMSServerControl
Throws:
java.lang.Exception

createTopic

public boolean createTopic(java.lang.String topicName,
                           java.lang.String jndiBinding)
                    throws java.lang.Exception
Specified by:
createTopic in interface JMSServerControl
Throws:
java.lang.Exception

destroyTopic

public boolean destroyTopic(java.lang.String name)
                     throws java.lang.Exception
Specified by:
destroyTopic in interface JMSServerControl
Throws:
java.lang.Exception

destroyConnectionFactory

public void destroyConnectionFactory(java.lang.String name)
                              throws java.lang.Exception
Specified by:
destroyConnectionFactory in interface JMSServerControl
Throws:
java.lang.Exception

isStarted

public boolean isStarted()
Specified by:
isStarted in interface JMSServerControl

getVersion

public java.lang.String getVersion()
Specified by:
getVersion in interface JMSServerControl

removeNotificationListener

public void removeNotificationListener(javax.management.NotificationListener listener,
                                       javax.management.NotificationFilter filter,
                                       java.lang.Object handback)
                                throws javax.management.ListenerNotFoundException
Specified by:
removeNotificationListener in interface javax.management.NotificationEmitter
Throws:
javax.management.ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(javax.management.NotificationListener listener)
                                throws javax.management.ListenerNotFoundException
Specified by:
removeNotificationListener in interface javax.management.NotificationBroadcaster
Throws:
javax.management.ListenerNotFoundException

addNotificationListener

public void addNotificationListener(javax.management.NotificationListener listener,
                                    javax.management.NotificationFilter filter,
                                    java.lang.Object handback)
                             throws java.lang.IllegalArgumentException
Specified by:
addNotificationListener in interface javax.management.NotificationBroadcaster
Throws:
java.lang.IllegalArgumentException

getNotificationInfo

public javax.management.MBeanNotificationInfo[] getNotificationInfo()
Specified by:
getNotificationInfo in interface javax.management.NotificationBroadcaster

listRemoteAddresses

public java.lang.String[] listRemoteAddresses()
                                       throws java.lang.Exception
Specified by:
listRemoteAddresses in interface JMSServerControl
Throws:
java.lang.Exception

listRemoteAddresses

public java.lang.String[] listRemoteAddresses(java.lang.String ipAddress)
                                       throws java.lang.Exception
Specified by:
listRemoteAddresses in interface JMSServerControl
Throws:
java.lang.Exception

closeConnectionsForAddress

public boolean closeConnectionsForAddress(java.lang.String ipAddress)
                                   throws java.lang.Exception
Specified by:
closeConnectionsForAddress in interface JMSServerControl
Throws:
java.lang.Exception

listConnectionIDs

public java.lang.String[] listConnectionIDs()
                                     throws java.lang.Exception
Specified by:
listConnectionIDs in interface JMSServerControl
Throws:
java.lang.Exception

listSessions

public java.lang.String[] listSessions(java.lang.String connectionID)
                                throws java.lang.Exception
Specified by:
listSessions in interface JMSServerControl
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.