[jboss-cvs] JBossAS SVN: r109640 - branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Wed Dec 1 22:21:08 EST 2010


Author: clebert.suconic at jboss.com
Date: 2010-12-01 22:21:08 -0500 (Wed, 01 Dec 2010)
New Revision: 109640

Modified:
   branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryManageMO.java
   branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryMapper.java
Log:
This would fail with the HornetQ 2.2. Commenting out for now only so we can fix it properly without compilation errors now

Modified: branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryManageMO.java
===================================================================
--- branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryManageMO.java	2010-12-02 02:13:30 UTC (rev 109639)
+++ branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryManageMO.java	2010-12-02 03:21:08 UTC (rev 109640)
@@ -180,12 +180,14 @@
    {
       if(liveTransportClassNames != null)
       {
-         jmsServerControl.createConnectionFactory(name, liveTransportClassNames, liveTransportParams == null?"":liveTransportParams,
-               backupTransportClassNames == null?"":backupTransportClassNames, backupTransportParams == null?"":backupTransportParams, bindings);
+    	// TODO for AndyTaylor: verify this
+//         jmsServerControl.createConnectionFactory(name, liveTransportClassNames, liveTransportParams == null?"":liveTransportParams,
+//               backupTransportClassNames == null?"":backupTransportClassNames, backupTransportParams == null?"":backupTransportParams, bindings);
       }
       else
       {
-         jmsServerControl.createConnectionFactory(name, discoveryAddress, discoveryPort, bindings);
+    	// TODO for AndyTaylor: verify this
+//         jmsServerControl.createConnectionFactory(name, discoveryAddress, discoveryPort, bindings);
       }
       ConnectionFactoryControl control = (ConnectionFactoryControl) managementService.getResource("jms.connectionfactory." + name);
       control.setDiscoveryRefreshTimeout(discoveryRefreshTimeout);
@@ -209,7 +211,8 @@
       control.setMaxRetryInterval(maxRetryInterval);
       control.setRetryIntervalMultiplier(retryIntervalMultiplier);
       control.setReconnectAttempts(reconnectAttempts);
-      control.setFailoverOnServerShutdown(failoverOnShutdown);
+   // TODO for AndyTaylor: verify this
+      //control.setFailoverOnServerShutdown(failoverOnShutdown);
       control.setScheduledThreadPoolMaxSize(scheduledThreadPoolMaxSize);
       control.setThreadPoolMaxSize(threadPoolMaxSize);
       control.setGroupID(groupId);
@@ -305,7 +308,8 @@
       control.setMaxRetryInterval(maxRetryInterval);
       control.setRetryIntervalMultiplier(retryIntervalMultiplier);
       control.setReconnectAttempts(reconnectAttempts);
-      control.setFailoverOnServerShutdown(failoverOnShutdown);
+      // TODO for AndyTaylor: verify this
+      //control.setFailoverOnServerShutdown(failoverOnShutdown);
       control.setScheduledThreadPoolMaxSize(scheduledThreadPoolMaxSize);
       control.setThreadPoolMaxSize(threadPoolMaxSize);
       control.setGroupID(groupId);

Modified: branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryMapper.java
===================================================================
--- branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryMapper.java	2010-12-02 02:13:30 UTC (rev 109639)
+++ branches/JBPAPP_5_1/hornetq-int/src/main/java/org/jboss/as/integration/hornetq/management/jms/ConnectionFactoryMapper.java	2010-12-02 03:21:08 UTC (rev 109640)
@@ -178,7 +178,8 @@
    {
       CompositeValueSupport cvs = new CompositeValueSupport(TYPE);
       cvs.set("name", new SimpleValueSupport(SimpleMetaType.STRING, control.getName()));
-      List<org.hornetq.api.core.Pair<TransportConfiguration, TransportConfiguration>> pairs = control.getStaticConnectors();
+   // TODO for AndyTaylor: verify this
+      List<org.hornetq.api.core.Pair<TransportConfiguration, TransportConfiguration>> pairs = null;
       StringBuffer liveTransportClassNames = new StringBuffer();
       StringBuffer liveTransportParams = new StringBuffer();
       StringBuffer backupTransportClassNames = new StringBuffer();
@@ -260,7 +261,8 @@
       cvs.set("MaxRetryInterval", new SimpleValueSupport(SimpleMetaType.STRING, control.getMaxRetryInterval()));
       cvs.set("RetryIntervalMultiplier", new SimpleValueSupport(SimpleMetaType.STRING, control.getRetryIntervalMultiplier()));
       cvs.set("ReconnectAttempts", new SimpleValueSupport(SimpleMetaType.STRING, control.getReconnectAttempts()));
-      cvs.set("FailoverOnServerShutdown", new SimpleValueSupport(SimpleMetaType.STRING, control.isFailoverOnServerShutdown()));
+   // TODO for AndyTaylor: verify this
+     // cvs.set("FailoverOnServerShutdown", new SimpleValueSupport(SimpleMetaType.STRING, control.isFailoverOnServerShutdown()));
       cvs.set("ScheduledThreadPoolMaxSize", new SimpleValueSupport(SimpleMetaType.STRING, control.getScheduledThreadPoolMaxSize()));
       cvs.set("ThreadPoolMaxSize", new SimpleValueSupport(SimpleMetaType.STRING, control.getThreadPoolMaxSize()));
       cvs.set("GroupID", new SimpleValueSupport(SimpleMetaType.STRING, control.getGroupID()));



More information about the jboss-cvs-commits mailing list