org.jboss.messaging.jms.server.management.jmx.impl
Class ReplicationAwareJMSServerControlWrapper
java.lang.Object
javax.management.StandardMBean
org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
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
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,
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 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 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 |
ReplicationAwareJMSServerControlWrapper
public ReplicationAwareJMSServerControlWrapper(JMSServerControlImpl localControl,
ReplicationOperationInvoker replicationInvoker)
throws java.lang.Exception
- 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
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,
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
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 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.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.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.