Author: rajdavies
Date: Wed Aug  5 06:35:56 2009
New Revision: 801075

URL: http://svn.apache.org/viewvc?rev=801075&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-2328

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java?rev=801075&r1=801074&r2=801075&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
 Wed Aug  5 06:35:56 2009
@@ -63,6 +63,7 @@
     private boolean locallyCreateMBeanServer;
     private boolean createConnector = true;
     private boolean findTigerMbeanServer = true;
+    private String connectorHost = "localhost";
     private int connectorPort = 1099;
     private int rmiServerPort;
     private String connectorPath = "/jmxrmi";
@@ -426,9 +427,9 @@
         if (rmiServerPort != 0) {
             // This is handy to use if you have a firewall and need to
             // force JMX to use fixed ports.
-            rmiServer = "localhost:" + rmiServerPort;
+            rmiServer = ""+getConnectorHost()+":" + rmiServerPort;
         }
-        String serviceURL = "service:jmx:rmi://" + rmiServer + 
"/jndi/rmi://localhost:" + connectorPort + connectorPath;
+        String serviceURL = "service:jmx:rmi://" + rmiServer + "/jndi/rmi://" 
+getConnectorHost()+":" + connectorPort + connectorPath;
         JMXServiceURL url = new JMXServiceURL(serviceURL);
         connectorServer = JMXConnectorServerFactory.newJMXConnectorServer(url, 
null, mbeanServer);
     }
@@ -464,4 +465,20 @@
     public void setCreateConnector(boolean createConnector) {
         this.createConnector = createConnector;
     }
+
+    /**
+     * Get the connectorHost
+     * @return the connectorHost
+     */
+    public String getConnectorHost() {
+        return this.connectorHost;
+    }
+
+    /**
+     * Set the connectorHost
+     * @param connectorHost the connectorHost to set
+     */
+    public void setConnectorHost(String connectorHost) {
+        this.connectorHost = connectorHost;
+    }
 }


Reply via email to