[jboss-cvs] JBoss Messaging SVN: r5870 - in trunk/src/main/org/jboss/messaging/jms/server/management: impl and 1 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Feb 16 09:38:05 EST 2009
Author: jmesnil
Date: 2009-02-16 09:38:04 -0500 (Mon, 16 Feb 2009)
New Revision: 5870
Modified:
trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControlMBean.java
trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java
trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java
Log:
added method to create a ConnectionFactory with a single connectorFactory
* no parameters are used, use all defaults for the given ConnectorFactory
* no backup connector can be configured
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControlMBean.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControlMBean.java 2009-02-16 14:36:03 UTC (rev 5869)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/JMSServerControlMBean.java 2009-02-16 14:38:04 UTC (rev 5870)
@@ -198,4 +198,30 @@
@Operation(desc = "List the sessions for the given connectionID", impact = INFO)
String[] listSessions(@Parameter(desc = "a connection ID", name = "connectionID") String connectionID);
+ void createSimpleConnectionFactory(String name,
+ String connectorFactoryClassName,
+ String connectionLoadBalancingPolicyClassName,
+ long pingPeriod,
+ long connectionTTL,
+ long callTimeout,
+ String clientID,
+ int dupsOKBatchSize,
+ int transactionBatchSize,
+ int consumerWindowSize,
+ int consumerMaxRate,
+ int producerWindowSize,
+ int producerMaxRate,
+ int minLargeMessageSize,
+ boolean blockOnAcknowledge,
+ boolean blockOnNonPersistentSend,
+ boolean blockOnPersistentSend,
+ boolean autoGroup,
+ int maxConnections,
+ boolean preAcknowledge,
+ long retryInterval,
+ double retryIntervalMultiplier,
+ int maxRetriesBeforeFailover,
+ int maxRetriesAfterFailover,
+ String jndiBinding) throws Exception;
+
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java 2009-02-16 14:36:03 UTC (rev 5869)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSServerControl.java 2009-02-16 14:38:04 UTC (rev 5870)
@@ -78,6 +78,69 @@
// JMSServerControlMBean implementation --------------------------
+ public void createSimpleConnectionFactory(String name,
+ String connectorFactoryClassName,
+ String connectionLoadBalancingPolicyClassName,
+ long pingPeriod,
+ long connectionTTL,
+ long callTimeout,
+ String clientID,
+ int dupsOKBatchSize,
+ int transactionBatchSize,
+ int consumerWindowSize,
+ int consumerMaxRate,
+ int producerWindowSize,
+ int producerMaxRate,
+ int minLargeMessageSize,
+ boolean blockOnAcknowledge,
+ boolean blockOnNonPersistentSend,
+ boolean blockOnPersistentSend,
+ boolean autoGroup,
+ int maxConnections,
+ boolean preAcknowledge,
+ long retryInterval,
+ double retryIntervalMultiplier,
+ int maxRetriesBeforeFailover,
+ int maxRetriesAfterFailover,
+ String jndiBinding) throws Exception
+ {
+ List<String> bindings = new ArrayList<String>();
+ bindings.add(jndiBinding);
+
+ List<Pair<TransportConfiguration, TransportConfiguration>> connectorConfigs = new ArrayList<Pair<TransportConfiguration, TransportConfiguration>>();
+ connectorConfigs.add(new Pair<TransportConfiguration, TransportConfiguration>(new TransportConfiguration(connectorFactoryClassName), null));
+
+ boolean created = server.createConnectionFactory(name,
+ connectorConfigs,
+ connectionLoadBalancingPolicyClassName,
+ pingPeriod,
+ connectionTTL,
+ callTimeout,
+ clientID,
+ dupsOKBatchSize,
+ transactionBatchSize,
+ consumerWindowSize,
+ consumerMaxRate,
+ producerWindowSize,
+ producerMaxRate,
+ minLargeMessageSize,
+ blockOnAcknowledge,
+ blockOnNonPersistentSend,
+ blockOnPersistentSend,
+ autoGroup,
+ maxConnections,
+ preAcknowledge,
+ retryInterval,
+ retryIntervalMultiplier,
+ maxRetriesBeforeFailover,
+ maxRetriesAfterFailover,
+ bindings);
+ if (created)
+ {
+ sendNotification(NotificationType.CONNECTION_FACTORY_CREATED, name);
+ }
+ }
+
public void createConnectionFactory(String name,
List<Pair<TransportConfiguration, TransportConfiguration>> connectorConfigs,
String connectionLoadBalancingPolicyClassName,
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java 2009-02-16 14:36:03 UTC (rev 5869)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/jmx/impl/ReplicationAwareJMSServerControlWrapper.java 2009-02-16 14:38:04 UTC (rev 5870)
@@ -71,6 +71,60 @@
return localControl.closeConnectionsForAddress(ipAddress);
}
+ public void createSimpleConnectionFactory(String name,
+ String connectorFactoryClassName,
+ String connectionLoadBalancingPolicyClassName,
+ long pingPeriod,
+ long connectionTTL,
+ long callTimeout,
+ String clientID,
+ int dupsOKBatchSize,
+ int transactionBatchSize,
+ int consumerWindowSize,
+ int consumerMaxRate,
+ int producerWindowSize,
+ int producerMaxRate,
+ int minLargeMessageSize,
+ boolean blockOnAcknowledge,
+ boolean blockOnNonPersistentSend,
+ boolean blockOnPersistentSend,
+ boolean autoGroup,
+ int maxConnections,
+ boolean preAcknowledge,
+ long retryInterval,
+ double retryIntervalMultiplier,
+ int maxRetriesBeforeFailover,
+ int maxRetriesAfterFailover,
+ String jndiBinding) throws Exception
+ {
+ replicationAwareInvoke("createSimpleConnectionFactory",
+ name,
+ connectorFactoryClassName,
+ connectionLoadBalancingPolicyClassName,
+ pingPeriod,
+ connectionTTL,
+ callTimeout,
+ clientID,
+ dupsOKBatchSize,
+ transactionBatchSize,
+ consumerWindowSize,
+ consumerMaxRate,
+ producerWindowSize,
+ producerMaxRate,
+ minLargeMessageSize,
+ blockOnAcknowledge,
+ blockOnNonPersistentSend,
+ blockOnPersistentSend,
+ autoGroup,
+ maxConnections,
+ preAcknowledge,
+ retryInterval,
+ retryIntervalMultiplier,
+ maxRetriesBeforeFailover,
+ maxRetriesAfterFailover,
+ jndiBinding);
+ }
+
public void createConnectionFactory(final String name,
final List<Pair<TransportConfiguration, TransportConfiguration>> connectorConfigs,
final String connectionLoadBalancingPolicyClassName,
More information about the jboss-cvs-commits
mailing list