Checkstyle fixes
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/afb9e70c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/afb9e70c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/afb9e70c Branch: refs/heads/master Commit: afb9e70c4ed4df8958312206460fbab2c0612ce2 Parents: f294ba2 Author: Grzegorz Grzybek <gr.grzy...@gmail.com> Authored: Tue Feb 11 11:38:02 2014 +0100 Committer: Grzegorz Grzybek <gr.grzy...@gmail.com> Committed: Tue Feb 11 11:38:02 2014 +0100 ---------------------------------------------------------------------- .../apache/camel/component/quickfixj/QuickfixjComponent.java | 5 +++-- .../org/apache/camel/component/quickfixj/QuickfixjEngine.java | 2 +- .../camel/component/quickfixj/QuickfixjLazyProducerTest.java | 6 +++--- 3 files changed, 7 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/afb9e70c/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java index 890d1d7..cd8c014 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java @@ -45,7 +45,7 @@ public class QuickfixjComponent extends DefaultComponent implements StartupListe private LogFactory logFactory; private MessageFactory messageFactory; private Map<String, QuickfixjConfiguration> configurations = new HashMap<String, QuickfixjConfiguration>(); - private boolean lazyCreateEngines = false; + private boolean lazyCreateEngines; @Override protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { @@ -68,8 +68,9 @@ public class QuickfixjComponent extends DefaultComponent implements StartupListe settings = QuickfixjEngine.loadSettings(remaining); } Boolean lazyCreateEngineForEndpoint = super.getAndRemoveParameter(parameters, PARAMETER_LAZY_CREATE_ENGINE, Boolean.TYPE); - if (lazyCreateEngineForEndpoint == null) + if (lazyCreateEngineForEndpoint == null) { lazyCreateEngineForEndpoint = isLazyCreateEngines(); + } engine = new QuickfixjEngine(uri, settings, messageStoreFactory, logFactory, messageFactory, lazyCreateEngineForEndpoint); http://git-wip-us.apache.org/repos/asf/camel/blob/afb9e70c/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java index c1fb9ff..1016d42 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java @@ -101,7 +101,7 @@ public class QuickfixjEngine extends ServiceSupport { private ObjectName initiatorObjectName; private final SessionSettings settings; private final AtomicBoolean initialized = new AtomicBoolean(false); - private boolean lazy = false; + private boolean lazy; public enum ThreadModel { ThreadPerConnector, ThreadPerSession; http://git-wip-us.apache.org/repos/asf/camel/blob/afb9e70c/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjLazyProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjLazyProducerTest.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjLazyProducerTest.java index dc1a2e3..fcc8b59 100644 --- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjLazyProducerTest.java +++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjLazyProducerTest.java @@ -16,9 +16,6 @@ */ package org.apache.camel.component.quickfixj; -import static org.hamcrest.CoreMatchers.*; -import static org.junit.Assert.*; - import org.apache.camel.Exchange; import org.apache.camel.ExchangePattern; import org.junit.Before; @@ -34,6 +31,9 @@ import quickfix.field.BeginString; import quickfix.field.SenderCompID; import quickfix.field.TargetCompID; +import static org.hamcrest.CoreMatchers.*; +import static org.junit.Assert.*; + public class QuickfixjLazyProducerTest { private Exchange mockExchange; private QuickfixjEndpoint endpoint;
