summaryrefslogtreecommitdiff
path: root/java
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
commit4913664e17d68821820b3550a4ecf476ef1300cd (patch)
tree51d94bf4911c069ea40f8be28d9f03f707c52fa5 /java
parent5534eb2d09899e1a4e9a06e6234bf32733c6d44b (diff)
downloadqpid-python-4913664e17d68821820b3550a4ecf476ef1300cd.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/qpid@1457612 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/Broker.java9
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java11
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java11
3 files changed, 29 insertions, 2 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/Broker.java b/java/broker/src/main/java/org/apache/qpid/server/Broker.java
index 2043b2cd67..d1be4213ec 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/Broker.java
+++ b/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/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java b/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java
index 23975ca6d5..289cfebc29 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/BrokerOptions.java
+++ b/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/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java b/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
index 7a7df66c57..51fe2d88d3 100644
--- a/java/broker/src/test/java/org/apache/qpid/server/BrokerOptionsTest.java
+++ b/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());
+ }
}