[camel] 04/04: CAMEL-12807 - Fixed CS

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit dd39d79cadd8eba9f2a8273bb234980dea76e19c
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Sep 14 15:38:56 2018 +0200

    CAMEL-12807 - Fixed CS
---
 .../src/main/java/org/apache/camel/component/paho/PahoEndpoint.java     | 2 +-
 .../test/java/org/apache/camel/component/paho/PahoComponentTest.java    | 2 +-
 .../java/org/apache/camel/component/paho/PahoOverrideTopicTest.java     | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
 
b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
index da08e77..86b6cc0 100644
--- 
a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
+++ 
b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
@@ -137,7 +137,7 @@ public class PahoEndpoint extends DefaultEndpoint {
             return connectOptions;
         }
         
-        if(resolveMqttConnectOptions) {
+        if (resolveMqttConnectOptions) {
             Set<MqttConnectOptions> connectOptions = 
getCamelContext().getRegistry().findByType(MqttConnectOptions.class);
             if (connectOptions.size() == 1) {
                 LOG.info("Single MqttConnectOptions instance found in the 
registry. It will be used by the endpoint.");
diff --git 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoComponentTest.java
 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoComponentTest.java
index e045482..4526b30 100644
--- 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoComponentTest.java
+++ 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoComponentTest.java
@@ -15,7 +15,6 @@
  * limitations under the License.
  */
 package org.apache.camel.component.paho;
-import org.junit.After;
 
 import java.io.UnsupportedEncodingException;
 
@@ -29,6 +28,7 @@ import org.apache.camel.test.AvailablePortFinder;
 import org.apache.camel.test.junit4.CamelTestSupport;
 import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.junit.After;
 import org.junit.Test;
 
 public class PahoComponentTest extends CamelTestSupport {
diff --git 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoOverrideTopicTest.java
 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoOverrideTopicTest.java
index 291b1de..2815698 100644
--- 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoOverrideTopicTest.java
+++ 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoOverrideTopicTest.java
@@ -15,7 +15,6 @@
  * limitations under the License.
  */
 package org.apache.camel.component.paho;
-import org.junit.After;
 
 import org.apache.activemq.broker.BrokerService;
 import org.apache.camel.builder.RouteBuilder;
@@ -23,6 +22,7 @@ import org.apache.camel.impl.JndiRegistry;
 import org.apache.camel.test.AvailablePortFinder;
 import org.apache.camel.test.junit4.CamelTestSupport;
 import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
+import org.junit.After;
 import org.junit.Test;
 
 public class PahoOverrideTopicTest extends CamelTestSupport {