summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2013-03-18 00:37:17 +0000
committerRobert Gemmell <robbie@apache.org>2013-03-18 00:37:17 +0000
commiteead9180dcdfcd233fa2c6cfde0194d1da6ce261 (patch)
tree897522e49f55a16aa3518e4eb86f7589cd084e77
parent4c2f59492e4e2d19bbf5d8e4020cb9a4401b16f6 (diff)
downloadqpid-python-eead9180dcdfcd233fa2c6cfde0194d1da6ce261.tar.gz
QPID-4655: add BrokerOptions support for skipping the logging configuration (and LoggingManagementMbean registration as a result) when embedding the broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1457612 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/Broker.java9
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java11
-rw-r--r--qpid/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java11
3 files changed, 29 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/Broker.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/Broker.java
index 2043b2cd67..d1be4213ec 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/Broker.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/Broker.java
@@ -115,8 +115,13 @@ public class Broker
CurrentActor.get().message(BrokerMessages.CONFIG(storeLocation));
- File logConfigFile = getConfigFile(options.getLogConfigFile(), BrokerOptions.DEFAULT_LOG_CONFIG_FILE, qpidHome, false);
- configureLogging(logConfigFile, options.getLogWatchFrequency());
+ //Allow skipping the logging configuration for people who are
+ //embedding the broker and want to configure it themselves.
+ if(!options.isSkipLoggingConfiguration())
+ {
+ File logConfigFile = getConfigFile(options.getLogConfigFile(), BrokerOptions.DEFAULT_LOG_CONFIG_FILE, qpidHome, false);
+ configureLogging(logConfigFile, options.getLogWatchFrequency());
+ }
BrokerConfigurationStoreCreator storeCreator = new BrokerConfigurationStoreCreator();
ConfigurationEntryStore store = storeCreator.createStore(storeLocation, storeType, options.getInitialConfigurationLocation());
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java
index 23975ca6d5..289cfebc29 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java
@@ -47,6 +47,7 @@ public class BrokerOptions
private int _managementModeConnectorPort;
private int _managementModeHttpPort;
private String _workingDir;
+ private boolean _skipLoggingConfiguration;
public String getLogConfigFile()
{
@@ -228,4 +229,14 @@ public class BrokerOptions
{
_initialConfigurationLocation = initialConfigurationLocation;
}
+
+ public boolean isSkipLoggingConfiguration()
+ {
+ return _skipLoggingConfiguration;
+ }
+
+ public void setSkipLoggingConfiguration(boolean skipLoggingConfiguration)
+ {
+ _skipLoggingConfiguration = skipLoggingConfiguration;
+ }
}
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
index 7a7df66c57..51fe2d88d3 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
@@ -186,4 +186,15 @@ public class BrokerOptionsTest extends QpidTestCase
_options.setWorkDir(testWorkDir);
assertEquals(testWorkDir, _options.getWorkDir());
}
+
+ public void testDefaultSkipLoggingConfiguration()
+ {
+ assertFalse(_options.isSkipLoggingConfiguration());
+ }
+
+ public void testOverriddenSkipLoggingConfiguration()
+ {
+ _options.setSkipLoggingConfiguration(true);
+ assertTrue(_options.isSkipLoggingConfiguration());
+ }
}