QPID-5687 : [Java Broker] fix the initial config store to use "type" not "pluginType", add a test that checks the broker will startup with no config store. Change the handling of ${amqp.qpid_port} and friends to allow setting through system properties

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1586938 13f79535-47bb-0310-9956-ffa450edef68

4 files changed, 27 insertions, 42 deletions

diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java
index 316d9bd88e..36d5b95936 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java
@@ -48,15 +48,6 @@ public class BrokerOptions
      * set in the "QPID_HOME" system property if that was set, or remains unset if it was not.
      */
     public static final String QPID_HOME_DIR  = "qpid.home_dir";
-    public static final String QPID_AMQP_PORT = "qpid.amqp_port";
-    public static final String QPID_HTTP_PORT = "qpid.http_port";
-    public static final String QPID_RMI_PORT  = "qpid.rmi_port";
-    public static final String QPID_JMX_PORT  = "qpid.jmx_port";
-
-    public static final String DEFAULT_AMQP_PORT_NUMBER = "5672";
-    public static final String DEFAULT_HTTP_PORT_NUMBER = "8080";
-    public static final String DEFAULT_RMI_PORT_NUMBER  = "8999";
-    public static final String DEFAULT_JMX_PORT_NUMBER  = "9099";
 
     public static final String DEFAULT_INITIAL_CONFIG_NAME = "initial-config.json";
     public static final String DEFAULT_STORE_TYPE = "json";
@@ -307,10 +298,6 @@ public class BrokerOptions
         ConcurrentHashMap<String, String> properties = new ConcurrentHashMap<String,String>();
         properties.putAll(_configProperties);
 
-        properties.putIfAbsent(QPID_AMQP_PORT, String.valueOf(DEFAULT_AMQP_PORT_NUMBER));
-        properties.putIfAbsent(QPID_HTTP_PORT, String.valueOf(DEFAULT_HTTP_PORT_NUMBER));
-        properties.putIfAbsent(QPID_RMI_PORT, String.valueOf(DEFAULT_RMI_PORT_NUMBER));
-        properties.putIfAbsent(QPID_JMX_PORT, String.valueOf(DEFAULT_JMX_PORT_NUMBER));
         properties.putIfAbsent(QPID_WORK_DIR, getWorkDir());
 
         String homeDir = getHomeDir();
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Broker.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Broker.java
index 6bb2e1beb3..5700f20356 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Broker.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Broker.java
@@ -59,9 +59,24 @@ public interface Broker<X extends Broker<X>> extends ConfiguredObject<X>, EventL
     String CONNECTION_HEART_BEAT_DELAY = "connection.heartBeatDelay";
     String CONNECTION_CLOSE_WHEN_NO_ROUTE = "connection.closeWhenNoRoute";
 
+
+    String QPID_AMQP_PORT = "qpid.amqp_port";
+    String QPID_HTTP_PORT = "qpid.http_port";
+    String QPID_RMI_PORT  = "qpid.rmi_port";
+    String QPID_JMX_PORT  = "qpid.jmx_port";
+
     @ManagedContextDefault(name = "broker.name")
     static final String DEFAULT_BROKER_NAME = "Broker";
 
+    @ManagedContextDefault(name = QPID_AMQP_PORT)
+    public static final String DEFAULT_AMQP_PORT_NUMBER = "5672";
+    @ManagedContextDefault(name = QPID_HTTP_PORT)
+    public static final String DEFAULT_HTTP_PORT_NUMBER = "8080";
+    @ManagedContextDefault(name = QPID_RMI_PORT)
+    public static final String DEFAULT_RMI_PORT_NUMBER  = "8999";
+    @ManagedContextDefault(name = QPID_JMX_PORT)
+    public static final String DEFAULT_JMX_PORT_NUMBER  = "9099";
+
     @ManagedAttribute( derived = true )
     String getBuildVersion();
 
diff --git a/qpid/java/broker-core/src/main/resources/initial-config.json b/qpid/java/broker-core/src/main/resources/initial-config.json
index 5cd53fa9cc..600822a033 100644
--- a/qpid/java/broker-core/src/main/resources/initial-config.json
+++ b/qpid/java/broker-core/src/main/resources/initial-config.json
@@ -61,10 +61,10 @@
     }
   } ],
   "plugins" : [ {
-    "pluginType" : "MANAGEMENT-HTTP",
+    "type" : "MANAGEMENT-HTTP",
     "name" : "httpManagement"
   }, {
-    "pluginType" : "MANAGEMENT-JMX",
+    "type" : "MANAGEMENT-JMX",
     "name" : "jmxManagement"
   } ]
 }
diff --git a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
index d60b852e55..d7301ddc19 100644
--- a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
+++ b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
@@ -227,13 +227,8 @@ public class BrokerOptionsTest extends QpidTestCase
 
         Map<String,String> props = _options.getConfigProperties();
 
-        assertEquals("unexpected number of entries", 5, props.keySet().size());
+        assertEquals("unexpected number of entries", 1, props.keySet().size());
 
-        assertEquals(BrokerOptions.DEFAULT_AMQP_PORT_NUMBER, props.get(BrokerOptions.QPID_AMQP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_HTTP_PORT_NUMBER, props.get(BrokerOptions.QPID_HTTP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_RMI_PORT_NUMBER, props.get(BrokerOptions.QPID_RMI_PORT));
-        assertEquals(BrokerOptions.DEFAULT_JMX_PORT_NUMBER, props.get(BrokerOptions.QPID_JMX_PORT));
-        assertEquals(BrokerOptions.DEFAULT_JMX_PORT_NUMBER, props.get(BrokerOptions.QPID_JMX_PORT));
         assertTrue(props.containsKey(BrokerOptions.QPID_WORK_DIR));
         assertFalse(props.containsKey(BrokerOptions.QPID_HOME_DIR));
     }
@@ -268,7 +263,7 @@ public class BrokerOptionsTest extends QpidTestCase
         setTestSystemProperty("QPID_HOME", qpidHome);
 
         assertEquals (qpidHome, _options.getConfigProperties().get(BrokerOptions.QPID_HOME_DIR));
-        assertEquals("unexpected number of entries", 6, _options.getConfigProperties().keySet().size());
+        assertEquals("unexpected number of entries", 2, _options.getConfigProperties().keySet().size());
     }
 
     public void testDefaultHomeDirWithoutQpidHome()
@@ -277,7 +272,7 @@ public class BrokerOptionsTest extends QpidTestCase
 
         assertNull(_options.getConfigProperties().get(BrokerOptions.QPID_HOME_DIR));
         assertFalse(_options.getConfigProperties().containsKey(BrokerOptions.QPID_HOME_DIR));
-        assertEquals("unexpected number of entries", 5, _options.getConfigProperties().keySet().size());
+        assertEquals("unexpected number of entries", 1, _options.getConfigProperties().keySet().size());
     }
 
     public void testOverriddenHomeDir()
@@ -285,7 +280,7 @@ public class BrokerOptionsTest extends QpidTestCase
         final String testHomeDir = "/my/test/home/dir";
         _options.setConfigProperty(BrokerOptions.QPID_HOME_DIR, testHomeDir);
         assertEquals(testHomeDir, _options.getConfigProperties().get(BrokerOptions.QPID_HOME_DIR));
-        assertEquals("unexpected number of entries", 6, _options.getConfigProperties().keySet().size());
+        assertEquals("unexpected number of entries", 2, _options.getConfigProperties().keySet().size());
     }
 
     public void testSetDefaultConfigProperties()
@@ -295,35 +290,23 @@ public class BrokerOptionsTest extends QpidTestCase
         setTestSystemProperty("QPID_WORK", null);
         setTestSystemProperty("QPID_HOME", null);
 
-        String oldPort = BrokerOptions.DEFAULT_AMQP_PORT_NUMBER;
         String newPort = "12345";
 
         //set a new value for a previously defaulted port number property
-        _options.setConfigProperty(BrokerOptions.QPID_AMQP_PORT, newPort);
+        _options.setConfigProperty(org.apache.qpid.server.model.Broker.QPID_AMQP_PORT, newPort);
         Map<String,String> props = _options.getConfigProperties();
-        assertEquals("unexpected number of entries", 5, props.keySet().size());
-        assertEquals(newPort, props.get(BrokerOptions.QPID_AMQP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_HTTP_PORT_NUMBER, props.get(BrokerOptions.QPID_HTTP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_RMI_PORT_NUMBER, props.get(BrokerOptions.QPID_RMI_PORT));
-        assertEquals(BrokerOptions.DEFAULT_JMX_PORT_NUMBER, props.get(BrokerOptions.QPID_JMX_PORT));
+        assertEquals("unexpected number of entries", 2, props.keySet().size());
+        assertEquals(newPort, props.get(org.apache.qpid.server.model.Broker.QPID_AMQP_PORT));
 
         //clear the value to ensure the default returns
-        _options.setConfigProperty(BrokerOptions.QPID_AMQP_PORT, null);
+        _options.setConfigProperty(org.apache.qpid.server.model.Broker.QPID_AMQP_PORT, null);
         props = _options.getConfigProperties();
-        assertEquals("unexpected number of entries", 5, props.keySet().size());
-        assertEquals(oldPort, props.get(BrokerOptions.QPID_AMQP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_HTTP_PORT_NUMBER, props.get(BrokerOptions.QPID_HTTP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_RMI_PORT_NUMBER, props.get(BrokerOptions.QPID_RMI_PORT));
-        assertEquals(BrokerOptions.DEFAULT_JMX_PORT_NUMBER, props.get(BrokerOptions.QPID_JMX_PORT));
+        assertEquals("unexpected number of entries", 1, props.keySet().size());
 
         //set a user specified property
         _options.setConfigProperty("name", "value");
         props = _options.getConfigProperties();
-        assertEquals("unexpected number of entries", 6, props.keySet().size());
-        assertEquals(oldPort, props.get(BrokerOptions.QPID_AMQP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_HTTP_PORT_NUMBER, props.get(BrokerOptions.QPID_HTTP_PORT));
-        assertEquals(BrokerOptions.DEFAULT_RMI_PORT_NUMBER, props.get(BrokerOptions.QPID_RMI_PORT));
-        assertEquals(BrokerOptions.DEFAULT_JMX_PORT_NUMBER, props.get(BrokerOptions.QPID_JMX_PORT));
+        assertEquals("unexpected number of entries", 2, props.keySet().size());
         assertEquals("value", props.get("name"));
     }
 }