org.jboss.messaging.jms.server.management.jmx.impl
Class ReplicationAwareJMSServerControlWrapper

java.lang.Object
  extended by javax.management.StandardMBean
      extended by org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
          extended by org.jboss.messaging.jms.server.management.jmx.impl.ReplicationAwareJMSServerControlWrapper
All Implemented Interfaces:
javax.management.DynamicMBean, JMSServerControl

public class ReplicationAwareJMSServerControlWrapper
extends ReplicationAwareStandardMBeanWrapper
implements JMSServerControl

A ReplicationAwareJMSServerControlWrapper

Author:
Jeff Mesnil, Tim Fox

Constructor Summary
ReplicationAwareJMSServerControlWrapper(JMSServerControlImpl localControl, ReplicationOperationInvoker replicationInvoker)
           
 
Method Summary
 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, 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.String 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 discoveryAddress, int discoveryPort, java.lang.String clientID, java.lang.String 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)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.lang.String liveTransportParams, java.lang.String jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassName, java.lang.String liveTransportParams, java.lang.String clientID, java.lang.String jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassNames, java.lang.String liveTransportParams, java.lang.String backupTransportClassNames, java.lang.String backupTransportParams, java.lang.String jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveConnectorsTransportClassNames, java.lang.String liveConnectorTransportParams, java.lang.String backupConnectorsTransportClassNames, java.lang.String 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.String jndiBindings)
           
 void createConnectionFactory(java.lang.String name, java.lang.String liveTransportClassNames, java.lang.String liveTransportParams, java.lang.String backupTransportClassNames, java.lang.String backupTransportParams, java.lang.String clientID, java.lang.String jndiBindings)
           
 boolean createQueue(java.lang.String name, java.lang.String jndiBinding)
           
 boolean createTopic(java.lang.String name, java.lang.String jndiBinding)
           
 void destroyConnectionFactory(java.lang.String name)
           
 boolean destroyQueue(java.lang.String name)
           
 boolean destroyTopic(java.lang.String name)
           
 javax.management.MBeanInfo getMBeanInfo()
           
 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)
           
 
Methods inherited from class org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
replicationAwareInvoke
 
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, setAttribute, setAttributes, setImplementation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReplicationAwareJMSServerControlWrapper

public ReplicationAwareJMSServerControlWrapper(JMSServerControlImpl localControl,
                                               ReplicationOperationInvoker replicationInvoker)
                                        throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

closeConnectionsForAddress

public boolean closeConnectionsForAddress(java.lang.String ipAddress)
                                   throws java.lang.Exception
Specified by:
closeConnectionsForAddress 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 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.String 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,
                                    java.lang.String 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

createConnectionFactory

public void createConnectionFactory(java.lang.String name,
                                    java.lang.String liveTransportClassNames,
                                    java.lang.String liveTransportParams,
                                    java.lang.String backupTransportClassNames,
                                    java.lang.String backupTransportParams,
                                    java.lang.String clientID,
                                    java.lang.String 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 liveTransportClassNames,
                                    java.lang.String liveTransportParams,
                                    java.lang.String backupTransportClassNames,
                                    java.lang.String backupTransportParams,
                                    java.lang.String 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.lang.String liveTransportParams,
                                    java.lang.String clientID,
                                    java.lang.String 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.lang.String liveTransportParams,
                                    java.lang.String 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.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 liveConnectorsTransportClassNames,
                                    java.lang.String liveConnectorTransportParams,
                                    java.lang.String backupConnectorsTransportClassNames,
                                    java.lang.String 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.String 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.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

createTopic

public boolean createTopic(java.lang.String name,
                           java.lang.String jndiBinding)
                    throws java.lang.Exception
Specified by:
createTopic 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

destroyQueue

public boolean destroyQueue(java.lang.String name)
                     throws java.lang.Exception
Specified by:
destroyQueue 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

getVersion

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

isStarted

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

listConnectionIDs

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

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

listSessions

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

getMBeanInfo

public javax.management.MBeanInfo getMBeanInfo()
Specified by:
getMBeanInfo in interface javax.management.DynamicMBean
Overrides:
getMBeanInfo in class javax.management.StandardMBean


Copyright © 2006 JBoss Inc. All Rights Reserved.