[hornetq-commits] JBoss hornetq SVN: r8978 - in trunk/src/main/org/hornetq: jms/management/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2010-03-27 06:16:27 -0400 (Sat, 27 Mar 2010)
New Revision: 8978

Modified:
   trunk/src/main/org/hornetq/api/jms/management/ConnectionFactoryControl.java
   trunk/src/main/org/hornetq/jms/management/impl/JMSConnectionFactoryControlImpl.java
Log:
added addJNDI method to cf control

Modified: trunk/src/main/org/hornetq/api/jms/management/ConnectionFactoryControl.java
===================================================================
--- trunk/src/main/org/hornetq/api/jms/management/ConnectionFactoryControl.java	2010-03-27 10:12:28 UTC (rev 8977)
+++ trunk/src/main/org/hornetq/api/jms/management/ConnectionFactoryControl.java	2010-03-27 10:16:27 UTC (rev 8978)
@@ -18,6 +18,8 @@
 import org.hornetq.api.core.Pair;
 import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.api.core.client.ClientSessionFactory;
+import org.hornetq.api.core.management.Operation;
+import org.hornetq.api.core.management.Parameter;
 
 /**
  * A ConnectionFactoryControl is used to manage a JMS ConnectionFactory.
@@ -387,4 +389,10 @@
     * @see ClientSessionFactory#setDiscoveryPort(int)
     */
    void setDiscoveryPort(int discoveryPort);
+
+   /**
+    * Add the JNDI binding to this destination
+    */
+   @Operation(desc = "Adds the factory to another JNDI binding")
+   void addJNDI(@Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI") String jndi) throws Exception;
 }

Modified: trunk/src/main/org/hornetq/jms/management/impl/JMSConnectionFactoryControlImpl.java
===================================================================
--- trunk/src/main/org/hornetq/jms/management/impl/JMSConnectionFactoryControlImpl.java	2010-03-27 10:12:28 UTC (rev 8977)
+++ trunk/src/main/org/hornetq/jms/management/impl/JMSConnectionFactoryControlImpl.java	2010-03-27 10:16:27 UTC (rev 8978)
@@ -21,6 +21,7 @@
 
 import org.hornetq.api.core.Pair;
 import org.hornetq.api.core.TransportConfiguration;
+import org.hornetq.api.core.management.Parameter;
 import org.hornetq.api.jms.management.ConnectionFactoryControl;
 import org.hornetq.core.management.impl.MBeanInfoHelper;
 import org.hornetq.jms.client.HornetQConnectionFactory;
@@ -317,6 +318,11 @@
       cf.setDiscoveryPort(discoveryPort);
    }
 
+   public void addJNDI(@Parameter(name = "jndiBinding", desc = "the name of the binding for JNDI") String jndi) throws Exception
+   {
+       jmsManager.addQueueToJndi(name, jndi);
+   }
+
    public long getCallTimeout()
    {
       return cf.getCallTimeout();