[hornetq-commits] JBoss hornetq SVN: r8978 - in trunk/src/main/org/hornetq: jms/management/impl and 1 other directory.
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();