camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [13/18] camel git commit: Apply code formatter
Date Wed, 12 Apr 2017 08:55:59 GMT
http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/AbstractMiloServerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/AbstractMiloServerTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/AbstractMiloServerTest.java
index a904de4..40115d2 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/AbstractMiloServerTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/AbstractMiloServerTest.java
@@ -28,63 +28,62 @@ import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
 
 public abstract class AbstractMiloServerTest extends CamelTestSupport {
 
-	public static void testBody(final AssertionClause clause, final Consumer<DataValue> valueConsumer) {
-		testBody(clause, DataValue.class, valueConsumer);
-	}
+    public static void testBody(final AssertionClause clause, final Consumer<DataValue> valueConsumer) {
+        testBody(clause, DataValue.class, valueConsumer);
+    }
 
-	public static <T> void testBody(final AssertionClause clause, final Class<T> bodyClass,
-			final Consumer<T> valueConsumer) {
-		clause.predicate(exchange -> {
-			final T body = exchange.getIn().getBody(bodyClass);
-			valueConsumer.accept(body);
-			return true;
-		});
-	}
+    public static <T> void testBody(final AssertionClause clause, final Class<T> bodyClass, final Consumer<T> valueConsumer) {
+        clause.predicate(exchange -> {
+            final T body = exchange.getIn().getBody(bodyClass);
+            valueConsumer.accept(body);
+            return true;
+        });
+    }
 
-	public static Consumer<DataValue> assertGoodValue(final Object expectedValue) {
-		return value -> {
-			assertNotNull(value);
-			assertEquals(expectedValue, value.getValue().getValue());
-			assertTrue(value.getStatusCode().isGood());
-			assertFalse(value.getStatusCode().isBad());
-		};
-	}
+    public static Consumer<DataValue> assertGoodValue(final Object expectedValue) {
+        return value -> {
+            assertNotNull(value);
+            assertEquals(expectedValue, value.getValue().getValue());
+            assertTrue(value.getStatusCode().isGood());
+            assertFalse(value.getStatusCode().isBad());
+        };
+    }
 
-	@Override
-	protected CamelContext createCamelContext() throws Exception {
-		final CamelContext context = super.createCamelContext();
-		configureContext(context);
-		return context;
-	}
+    @Override
+    protected CamelContext createCamelContext() throws Exception {
+        final CamelContext context = super.createCamelContext();
+        configureContext(context);
+        return context;
+    }
 
-	protected void configureContext(final CamelContext context) throws Exception {
-		final MiloServerComponent server = context.getComponent("milo-server", MiloServerComponent.class);
-		configureMiloServer(server);
-	}
+    protected void configureContext(final CamelContext context) throws Exception {
+        final MiloServerComponent server = context.getComponent("milo-server", MiloServerComponent.class);
+        configureMiloServer(server);
+    }
 
-	protected void configureMiloServer(final MiloServerComponent server) throws Exception {
-		server.setBindAddresses("localhost");
-		server.setBindPort(12685);
-		server.setUserAuthenticationCredentials("foo:bar,foo2:bar2");
-	}
+    protected void configureMiloServer(final MiloServerComponent server) throws Exception {
+        server.setBindAddresses("localhost");
+        server.setBindPort(12685);
+        server.setUserAuthenticationCredentials("foo:bar,foo2:bar2");
+    }
 
-	/**
-	 * Create a default key store for testing
-	 *
-	 * @return always returns a key store
-	 */
-	protected KeyStoreLoader.Result loadDefaultTestKey() {
-		try {
+    /**
+     * Create a default key store for testing
+     *
+     * @return always returns a key store
+     */
+    protected KeyStoreLoader.Result loadDefaultTestKey() {
+        try {
 
-			final KeyStoreLoader loader = new KeyStoreLoader();
-			loader.setUrl("file:src/test/resources/cert/cert.p12");
-			loader.setKeyStorePassword("pwd1");
-			loader.setKeyPassword("pwd1");
-			return loader.load();
-		} catch (final GeneralSecurityException | IOException e) {
-			throw new RuntimeException(e);
-		}
+            final KeyStoreLoader loader = new KeyStoreLoader();
+            loader.setUrl("file:src/test/resources/cert/cert.p12");
+            loader.setKeyStorePassword("pwd1");
+            loader.setKeyPassword("pwd1");
+            return loader.load();
+        } catch (final GeneralSecurityException | IOException e) {
+            throw new RuntimeException(e);
+        }
 
-	}
+    }
 
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsCertTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsCertTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsCertTest.java
index 3328902..e397520 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsCertTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsCertTest.java
@@ -36,89 +36,88 @@ import org.junit.Test;
  */
 public class MonitorItemMultiConnectionsCertTest extends AbstractMiloServerTest {
 
-	private static final String DIRECT_START_1 = "direct:start1";
-
-	private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
-
-	// with key
-	private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node="
-			+ NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1")
-			+ "&keyStoreUrl=file:src/test/resources/cert/cert.p12&keyStorePassword=pwd1&keyPassword=pwd1";
-
-	// with wrong password
-	private static final String MILO_CLIENT_ITEM_C2_1 = "milo-client:tcp://foo:bar2@localhost:12685?node="
-			+ NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
-
-	// without key, clientId=1
-	private static final String MILO_CLIENT_ITEM_C3_1 = "milo-client:tcp://foo:bar@localhost:12685?clientId=1&node="
-			+ NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
-
-	private static final String MOCK_TEST_1 = "mock:test1";
-	private static final String MOCK_TEST_2 = "mock:test2";
-	private static final String MOCK_TEST_3 = "mock:test3";
-
-	@EndpointInject(uri = MOCK_TEST_1)
-	protected MockEndpoint test1Endpoint;
-
-	@EndpointInject(uri = MOCK_TEST_2)
-	protected MockEndpoint test2Endpoint;
-
-	@EndpointInject(uri = MOCK_TEST_3)
-	protected MockEndpoint test3Endpoint;
-
-	@Produce(uri = DIRECT_START_1)
-	protected ProducerTemplate producer1;
-
-	@Override
-	protected void configureMiloServer(final MiloServerComponent server) throws Exception {
-		super.configureMiloServer(server);
-
-		final Path baseDir = Paths.get("target/testing/cert/default");
-		final Path trusted = baseDir.resolve("trusted");
-
-		Files.createDirectories(trusted);
-		Files.copy(Paths.get("src/test/resources/cert/certificate.der"), trusted.resolve("certificate.der"),
-				REPLACE_EXISTING);
-
-		server.setServerCertificate(loadDefaultTestKey());
-		server.setDefaultCertificateValidator(baseDir.toFile());
-	}
-
-	@Override
-	protected RoutesBuilder createRouteBuilder() throws Exception {
-		return new RouteBuilder() {
-			@Override
-			public void configure() throws Exception {
-				from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
-
-				from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
-				from(MILO_CLIENT_ITEM_C2_1).to(MOCK_TEST_2);
-				from(MILO_CLIENT_ITEM_C3_1).to(MOCK_TEST_3);
-			}
-		};
-	}
-
-	/**
-	 * Monitor multiple connections, but only one has the correct credentials
-	 */
-	@Test
-	public void testMonitorItem1() throws Exception {
-		// set server value
-		this.producer1.sendBody("Foo");
-
-		// item 1 ... only this one receives
-		this.test1Endpoint.setExpectedCount(1);
-		this.test1Endpoint.setSleepForEmptyTest(5_000);
-
-		// item 2
-		this.test2Endpoint.setExpectedCount(0);
-		this.test2Endpoint.setSleepForEmptyTest(5_000);
-
-		// item 3
-		this.test3Endpoint.setExpectedCount(0);
-		this.test3Endpoint.setSleepForEmptyTest(5_000);
-
-		// assert
-		this.assertMockEndpointsSatisfied();
-	}
+    private static final String DIRECT_START_1 = "direct:start1";
+
+    private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
+
+    // with key
+    private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1")
+                                                        + "&keyStoreUrl=file:src/test/resources/cert/cert.p12&keyStorePassword=pwd1&keyPassword=pwd1";
+
+    // with wrong password
+    private static final String MILO_CLIENT_ITEM_C2_1 = "milo-client:tcp://foo:bar2@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+
+    // without key, clientId=1
+    private static final String MILO_CLIENT_ITEM_C3_1 = "milo-client:tcp://foo:bar@localhost:12685?clientId=1&node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+
+    private static final String MOCK_TEST_1 = "mock:test1";
+    private static final String MOCK_TEST_2 = "mock:test2";
+    private static final String MOCK_TEST_3 = "mock:test3";
+
+    @EndpointInject(uri = MOCK_TEST_1)
+    protected MockEndpoint test1Endpoint;
+
+    @EndpointInject(uri = MOCK_TEST_2)
+    protected MockEndpoint test2Endpoint;
+
+    @EndpointInject(uri = MOCK_TEST_3)
+    protected MockEndpoint test3Endpoint;
+
+    @Produce(uri = DIRECT_START_1)
+    protected ProducerTemplate producer1;
+
+    @Override
+    protected void configureMiloServer(final MiloServerComponent server) throws Exception {
+        super.configureMiloServer(server);
+
+        final Path baseDir = Paths.get("target/testing/cert/default");
+        final Path trusted = baseDir.resolve("trusted");
+
+        Files.createDirectories(trusted);
+        Files.copy(Paths.get("src/test/resources/cert/certificate.der"), trusted.resolve("certificate.der"), REPLACE_EXISTING);
+
+        server.setServerCertificate(loadDefaultTestKey());
+        server.setDefaultCertificateValidator(baseDir.toFile());
+    }
+
+    @Override
+    protected RoutesBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
+
+                from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
+                from(MILO_CLIENT_ITEM_C2_1).to(MOCK_TEST_2);
+                from(MILO_CLIENT_ITEM_C3_1).to(MOCK_TEST_3);
+            }
+        };
+    }
+
+    /**
+     * Monitor multiple connections, but only one has the correct credentials
+     */
+    @Test
+    public void testMonitorItem1() throws Exception {
+        // set server value
+        this.producer1.sendBody("Foo");
+
+        // item 1 ... only this one receives
+        this.test1Endpoint.setExpectedCount(1);
+        this.test1Endpoint.setSleepForEmptyTest(5_000);
+
+        // item 2
+        this.test2Endpoint.setExpectedCount(0);
+        this.test2Endpoint.setSleepForEmptyTest(5_000);
+
+        // item 3
+        this.test3Endpoint.setExpectedCount(0);
+        this.test3Endpoint.setSleepForEmptyTest(5_000);
+
+        // assert
+        this.assertMockEndpointsSatisfied();
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsTest.java
index 791e4e4..bb5463c 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemMultiConnectionsTest.java
@@ -30,67 +30,70 @@ import org.junit.Test;
  */
 public class MonitorItemMultiConnectionsTest extends AbstractMiloServerTest {
 
-	private static final String DIRECT_START_1 = "direct:start1";
+    private static final String DIRECT_START_1 = "direct:start1";
 
-	private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
+    private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
 
-	private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node=" + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
 
-	private static final String MILO_CLIENT_ITEM_C2_1 = "milo-client:tcp://foo:bar2@localhost:12685?node=" + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C2_1 = "milo-client:tcp://foo:bar2@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
 
-	private static final String MILO_CLIENT_ITEM_C3_1 = "milo-client:tcp://foo2:bar@localhost:12685?node=" + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C3_1 = "milo-client:tcp://foo2:bar@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
 
-	private static final String MOCK_TEST_1 = "mock:test1";
-	private static final String MOCK_TEST_2 = "mock:test2";
-	private static final String MOCK_TEST_3 = "mock:test3";
+    private static final String MOCK_TEST_1 = "mock:test1";
+    private static final String MOCK_TEST_2 = "mock:test2";
+    private static final String MOCK_TEST_3 = "mock:test3";
 
-	@EndpointInject(uri = MOCK_TEST_1)
-	protected MockEndpoint test1Endpoint;
+    @EndpointInject(uri = MOCK_TEST_1)
+    protected MockEndpoint test1Endpoint;
 
-	@EndpointInject(uri = MOCK_TEST_2)
-	protected MockEndpoint test2Endpoint;
+    @EndpointInject(uri = MOCK_TEST_2)
+    protected MockEndpoint test2Endpoint;
 
-	@EndpointInject(uri = MOCK_TEST_3)
-	protected MockEndpoint test3Endpoint;
+    @EndpointInject(uri = MOCK_TEST_3)
+    protected MockEndpoint test3Endpoint;
 
-	@Produce(uri = DIRECT_START_1)
-	protected ProducerTemplate producer1;
+    @Produce(uri = DIRECT_START_1)
+    protected ProducerTemplate producer1;
 
-	@Override
-	protected RoutesBuilder createRouteBuilder() throws Exception {
-		return new RouteBuilder() {
-			@Override
-			public void configure() throws Exception {
-				from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
+    @Override
+    protected RoutesBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
 
-				from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
-				from(MILO_CLIENT_ITEM_C2_1).to(MOCK_TEST_2);
-				from(MILO_CLIENT_ITEM_C3_1).to(MOCK_TEST_3);
-			}
-		};
-	}
+                from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
+                from(MILO_CLIENT_ITEM_C2_1).to(MOCK_TEST_2);
+                from(MILO_CLIENT_ITEM_C3_1).to(MOCK_TEST_3);
+            }
+        };
+    }
 
-	/**
-	 * Monitor multiple connections, but only one has the correct credentials
-	 */
-	@Test
-	public void testMonitorItem1() throws Exception {
-		// set server value
-		this.producer1.sendBody("Foo");
+    /**
+     * Monitor multiple connections, but only one has the correct credentials
+     */
+    @Test
+    public void testMonitorItem1() throws Exception {
+        // set server value
+        this.producer1.sendBody("Foo");
 
-		// item 1 ... only this one receives
-		this.test1Endpoint.setExpectedCount(1);
-		this.test1Endpoint.setSleepForEmptyTest(5_000);
+        // item 1 ... only this one receives
+        this.test1Endpoint.setExpectedCount(1);
+        this.test1Endpoint.setSleepForEmptyTest(5_000);
 
-		// item 2
-		this.test2Endpoint.setExpectedCount(0);
-		this.test2Endpoint.setSleepForEmptyTest(5_000);
+        // item 2
+        this.test2Endpoint.setExpectedCount(0);
+        this.test2Endpoint.setSleepForEmptyTest(5_000);
 
-		// item 3
-		this.test3Endpoint.setExpectedCount(0);
-		this.test3Endpoint.setSleepForEmptyTest(5_000);
+        // item 3
+        this.test3Endpoint.setExpectedCount(0);
+        this.test3Endpoint.setSleepForEmptyTest(5_000);
 
-		// assert
-		this.assertMockEndpointsSatisfied();
-	}
+        // assert
+        this.assertMockEndpointsSatisfied();
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemTest.java
index 6c11b64..bca304c 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemTest.java
@@ -30,59 +30,60 @@ import org.junit.Test;
  */
 public class MonitorItemTest extends AbstractMiloServerTest {
 
-	private static final String DIRECT_START_1 = "direct:start1";
+    private static final String DIRECT_START_1 = "direct:start1";
 
-	private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
+    private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
 
-	private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node=" + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C1_1 = "milo-client:tcp://foo:bar@localhost:12685?node="
+                                                        + NodeIds.nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
 
-	private static final String MOCK_TEST_1 = "mock:test1";
+    private static final String MOCK_TEST_1 = "mock:test1";
 
-	@EndpointInject(uri = MOCK_TEST_1)
-	protected MockEndpoint test1Endpoint;
+    @EndpointInject(uri = MOCK_TEST_1)
+    protected MockEndpoint test1Endpoint;
 
-	@Produce(uri = DIRECT_START_1)
-	protected ProducerTemplate producer1;
+    @Produce(uri = DIRECT_START_1)
+    protected ProducerTemplate producer1;
 
-	@Override
-	protected RoutesBuilder createRouteBuilder() throws Exception {
-		return new RouteBuilder() {
-			@Override
-			public void configure() throws Exception {
-				from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
+    @Override
+    protected RoutesBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from(DIRECT_START_1).to(MILO_SERVER_ITEM_1);
 
-				from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
-			}
-		};
-	}
+                from(MILO_CLIENT_ITEM_C1_1).to(MOCK_TEST_1);
+            }
+        };
+    }
 
-	/**
-	 * Monitor multiple events
-	 */
-	@Test
-	public void testMonitorItem1() throws Exception {
-		/*
-		 * we will wait 2 * 1_000 milliseconds between server updates since the
-		 * default server update rate is 1_000 milliseconds
-		 */
+    /**
+     * Monitor multiple events
+     */
+    @Test
+    public void testMonitorItem1() throws Exception {
+        /*
+         * we will wait 2 * 1_000 milliseconds between server updates since the
+         * default server update rate is 1_000 milliseconds
+         */
 
-		// set server values
-		this.producer1.sendBody("Foo");
-		Thread.sleep(2_000);
-		this.producer1.sendBody("Bar");
-		Thread.sleep(2_000);
-		this.producer1.sendBody("Baz");
-		Thread.sleep(2_000);
+        // set server values
+        this.producer1.sendBody("Foo");
+        Thread.sleep(2_000);
+        this.producer1.sendBody("Bar");
+        Thread.sleep(2_000);
+        this.producer1.sendBody("Baz");
+        Thread.sleep(2_000);
 
-		// item 1 ... only this one receives
-		this.test1Endpoint.setExpectedCount(3);
+        // item 1 ... only this one receives
+        this.test1Endpoint.setExpectedCount(3);
 
-		// tests
-		testBody(this.test1Endpoint.message(0), assertGoodValue("Foo"));
-		testBody(this.test1Endpoint.message(1), assertGoodValue("Bar"));
-		testBody(this.test1Endpoint.message(2), assertGoodValue("Baz"));
+        // tests
+        testBody(this.test1Endpoint.message(0), assertGoodValue("Foo"));
+        testBody(this.test1Endpoint.message(1), assertGoodValue("Bar"));
+        testBody(this.test1Endpoint.message(2), assertGoodValue("Baz"));
 
-		// assert
-		this.assertMockEndpointsSatisfied();
-	}
+        // assert
+        this.assertMockEndpointsSatisfied();
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/NodeIdTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/NodeIdTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/NodeIdTest.java
index a832f87..857d7a0 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/NodeIdTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/NodeIdTest.java
@@ -32,61 +32,55 @@ import org.junit.Test;
  */
 public class NodeIdTest extends AbstractMiloServerTest {
 
-	@Test
-	public void testFull1() {
-		final String s = String.format("nsu=%s;s=%s", DEFAULT_NAMESPACE_URI, "item-1");
-		testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")",
-				DEFAULT_NAMESPACE_URI, "item-1");
-	}
-
-	@Test
-	public void testFull2() {
-		final String s = String.format("ns=%s;s=%s", 1, "item-1");
-		testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")", ushort(1),
-				"item-1");
-	}
-
-	@Test
-	public void testFull3() {
-		final String s = String.format("ns=%s;i=%s", 1, 2);
-		testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")", ushort(1),
-				uint(2));
-	}
-
-	@Test
-	public void testFull1NonRaw() {
-		final String s = String.format("ns=%s;i=%s", 1, 2);
-		testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node="
-				+ urlFormParameterEscaper().escape(s), ushort(1), uint(2));
-	}
-
-	@Test
-	public void testDocURL() {
-		testUri("milo-client://user:password@localhost:12345?node=RAW(nsu=http://foo.bar;s=foo/bar)", "http://foo.bar",
-				"foo/bar");
-	}
-
-	@Test(expected = ResolveEndpointFailedException.class)
-	public void testMixed() {
-		// This must fail since "node" is incomplete
-		testUri("milo-client:tcp://foo:bar@localhost:12685?node=foo&namespaceUri=" + DEFAULT_NAMESPACE_URI, null, null);
-	}
-
-	private void testUri(final String uri, final Serializable namespace, final Serializable partialNodeId) {
-		assertNodeId(getMandatoryEndpoint(uri, MiloClientEndpoint.class), namespace, partialNodeId);
-	}
-
-	private void assertNodeId(final MiloClientEndpoint endpoint, final Serializable namespace,
-			final Serializable partialNodeId) {
-
-		final NamespaceId ns = endpoint.makeNamespaceId();
-		final PartialNodeId pn = endpoint.makePartialNodeId();
-
-		assertNotNull(ns);
-		assertNotNull(pn);
-
-		assertEquals(namespace, ns.getValue());
-		assertEquals(partialNodeId, pn.getValue());
-	}
+    @Test
+    public void testFull1() {
+        final String s = String.format("nsu=%s;s=%s", DEFAULT_NAMESPACE_URI, "item-1");
+        testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")", DEFAULT_NAMESPACE_URI, "item-1");
+    }
+
+    @Test
+    public void testFull2() {
+        final String s = String.format("ns=%s;s=%s", 1, "item-1");
+        testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")", ushort(1), "item-1");
+    }
+
+    @Test
+    public void testFull3() {
+        final String s = String.format("ns=%s;i=%s", 1, 2);
+        testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=RAW(" + s + ")", ushort(1), uint(2));
+    }
+
+    @Test
+    public void testFull1NonRaw() {
+        final String s = String.format("ns=%s;i=%s", 1, 2);
+        testUri("milo-client:tcp://foo:bar@localhost:12685?samplingInterval=1000&node=" + urlFormParameterEscaper().escape(s), ushort(1), uint(2));
+    }
+
+    @Test
+    public void testDocURL() {
+        testUri("milo-client://user:password@localhost:12345?node=RAW(nsu=http://foo.bar;s=foo/bar)", "http://foo.bar", "foo/bar");
+    }
+
+    @Test(expected = ResolveEndpointFailedException.class)
+    public void testMixed() {
+        // This must fail since "node" is incomplete
+        testUri("milo-client:tcp://foo:bar@localhost:12685?node=foo&namespaceUri=" + DEFAULT_NAMESPACE_URI, null, null);
+    }
+
+    private void testUri(final String uri, final Serializable namespace, final Serializable partialNodeId) {
+        assertNodeId(getMandatoryEndpoint(uri, MiloClientEndpoint.class), namespace, partialNodeId);
+    }
+
+    private void assertNodeId(final MiloClientEndpoint endpoint, final Serializable namespace, final Serializable partialNodeId) {
+
+        final NamespaceId ns = endpoint.makeNamespaceId();
+        final PartialNodeId pn = endpoint.makePartialNodeId();
+
+        assertNotNull(ns);
+        assertNotNull(pn);
+
+        assertEquals(namespace, ns.getValue());
+        assertEquals(partialNodeId, pn.getValue());
+    }
 
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/WriteClientTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/WriteClientTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/WriteClientTest.java
index 4216038..abf675d 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/WriteClientTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/WriteClientTest.java
@@ -33,122 +33,122 @@ import org.junit.Test;
  */
 public class WriteClientTest extends AbstractMiloServerTest {
 
-	private static final String DIRECT_START_1 = "direct:start1";
-	private static final String DIRECT_START_2 = "direct:start2";
-	private static final String DIRECT_START_3 = "direct:start3";
-	private static final String DIRECT_START_4 = "direct:start4";
-
-	private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
-	private static final String MILO_SERVER_ITEM_2 = "milo-server:myitem2";
-
-	private static final String MILO_CLIENT_BASE_C1 = "milo-client:tcp://foo:bar@localhost:12685";
-	private static final String MILO_CLIENT_BASE_C2 = "milo-client:tcp://foo2:bar2@localhost:12685";
-
-	private static final String MILO_CLIENT_ITEM_C1_1 = MILO_CLIENT_BASE_C1 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
-	private static final String MILO_CLIENT_ITEM_C1_2 = MILO_CLIENT_BASE_C1 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem2");
-	
-	private static final String MILO_CLIENT_ITEM_C2_1 = MILO_CLIENT_BASE_C2 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
-	private static final String MILO_CLIENT_ITEM_C2_2 = MILO_CLIENT_BASE_C2 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem2");
-
-	private static final String MOCK_TEST_1 = "mock:test1";
-	private static final String MOCK_TEST_2 = "mock:test2";
-
-	@EndpointInject(uri = MOCK_TEST_1)
-	protected MockEndpoint test1Endpoint;
-
-	@EndpointInject(uri = MOCK_TEST_2)
-	protected MockEndpoint test2Endpoint;
-
-	@Produce(uri = DIRECT_START_1)
-	protected ProducerTemplate producer1;
-
-	@Produce(uri = DIRECT_START_2)
-	protected ProducerTemplate producer2;
-
-	@Produce(uri = DIRECT_START_3)
-	protected ProducerTemplate producer3;
-
-	@Produce(uri = DIRECT_START_4)
-	protected ProducerTemplate producer4;
-
-	@Override
-	protected RoutesBuilder createRouteBuilder() throws Exception {
-		return new RouteBuilder() {
-			@Override
-			public void configure() throws Exception {
-
-				from(MILO_SERVER_ITEM_1).to(MOCK_TEST_1);
-				from(MILO_SERVER_ITEM_2).to(MOCK_TEST_2);
-
-				from(DIRECT_START_1).to(MILO_CLIENT_ITEM_C1_1);
-				from(DIRECT_START_2).to(MILO_CLIENT_ITEM_C1_2);
-
-				from(DIRECT_START_3).to(MILO_CLIENT_ITEM_C2_1);
-				from(DIRECT_START_4).to(MILO_CLIENT_ITEM_C2_2);
-			}
-		};
-	}
-
-	@Test
-	public void testWrite1() throws Exception {
-		// item 1
-		this.test1Endpoint.setExpectedCount(2);
-		testBody(this.test1Endpoint.message(0), assertGoodValue("Foo1"));
-		testBody(this.test1Endpoint.message(1), assertGoodValue("Foo2"));
-
-		// item 2
-		this.test2Endpoint.setExpectedCount(0);
-
-		// send
-		sendValue(this.producer1, new Variant("Foo1"));
-		sendValue(this.producer1, new Variant("Foo2"));
-
-		// assert
-		this.assertMockEndpointsSatisfied();
-	}
-
-	@Test
-	public void testWrite2() throws Exception {
-		// item 1
-		this.test1Endpoint.setExpectedCount(0);
-
-		// item 2
-		this.test2Endpoint.setExpectedCount(2);
-		testBody(this.test2Endpoint.message(0), assertGoodValue("Foo1"));
-		testBody(this.test2Endpoint.message(1), assertGoodValue("Foo2"));
-
-		// send
-		sendValue(this.producer2, new Variant("Foo1"));
-		sendValue(this.producer2, new Variant("Foo2"));
-
-		// assert
-		this.assertMockEndpointsSatisfied();
-	}
-
-	@Test
-	public void testWrite3() throws Exception {
-		// item 1
-		this.test1Endpoint.setExpectedCount(2);
-		testBody(this.test1Endpoint.message(0), assertGoodValue("Foo1"));
-		testBody(this.test1Endpoint.message(1), assertGoodValue("Foo3"));
-
-		// item 1
-		this.test2Endpoint.setExpectedCount(2);
-		testBody(this.test2Endpoint.message(0), assertGoodValue("Foo2"));
-		testBody(this.test2Endpoint.message(1), assertGoodValue("Foo4"));
-
-		// send
-		sendValue(this.producer1, new Variant("Foo1"));
-		sendValue(this.producer2, new Variant("Foo2"));
-		sendValue(this.producer3, new Variant("Foo3"));
-		sendValue(this.producer4, new Variant("Foo4"));
-
-		// assert
-		assertMockEndpointsSatisfied();
-	}
-
-	private static void sendValue(final ProducerTemplate producerTemplate, final Variant variant) {
-		// we always write synchronously since we do need the message order
-		producerTemplate.sendBodyAndHeader(variant, "await", true);
-	}
+    private static final String DIRECT_START_1 = "direct:start1";
+    private static final String DIRECT_START_2 = "direct:start2";
+    private static final String DIRECT_START_3 = "direct:start3";
+    private static final String DIRECT_START_4 = "direct:start4";
+
+    private static final String MILO_SERVER_ITEM_1 = "milo-server:myitem1";
+    private static final String MILO_SERVER_ITEM_2 = "milo-server:myitem2";
+
+    private static final String MILO_CLIENT_BASE_C1 = "milo-client:tcp://foo:bar@localhost:12685";
+    private static final String MILO_CLIENT_BASE_C2 = "milo-client:tcp://foo2:bar2@localhost:12685";
+
+    private static final String MILO_CLIENT_ITEM_C1_1 = MILO_CLIENT_BASE_C1 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C1_2 = MILO_CLIENT_BASE_C1 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem2");
+
+    private static final String MILO_CLIENT_ITEM_C2_1 = MILO_CLIENT_BASE_C2 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem1");
+    private static final String MILO_CLIENT_ITEM_C2_2 = MILO_CLIENT_BASE_C2 + "?node=" + nodeValue(MiloServerComponent.DEFAULT_NAMESPACE_URI, "items-myitem2");
+
+    private static final String MOCK_TEST_1 = "mock:test1";
+    private static final String MOCK_TEST_2 = "mock:test2";
+
+    @EndpointInject(uri = MOCK_TEST_1)
+    protected MockEndpoint test1Endpoint;
+
+    @EndpointInject(uri = MOCK_TEST_2)
+    protected MockEndpoint test2Endpoint;
+
+    @Produce(uri = DIRECT_START_1)
+    protected ProducerTemplate producer1;
+
+    @Produce(uri = DIRECT_START_2)
+    protected ProducerTemplate producer2;
+
+    @Produce(uri = DIRECT_START_3)
+    protected ProducerTemplate producer3;
+
+    @Produce(uri = DIRECT_START_4)
+    protected ProducerTemplate producer4;
+
+    @Override
+    protected RoutesBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+
+                from(MILO_SERVER_ITEM_1).to(MOCK_TEST_1);
+                from(MILO_SERVER_ITEM_2).to(MOCK_TEST_2);
+
+                from(DIRECT_START_1).to(MILO_CLIENT_ITEM_C1_1);
+                from(DIRECT_START_2).to(MILO_CLIENT_ITEM_C1_2);
+
+                from(DIRECT_START_3).to(MILO_CLIENT_ITEM_C2_1);
+                from(DIRECT_START_4).to(MILO_CLIENT_ITEM_C2_2);
+            }
+        };
+    }
+
+    @Test
+    public void testWrite1() throws Exception {
+        // item 1
+        this.test1Endpoint.setExpectedCount(2);
+        testBody(this.test1Endpoint.message(0), assertGoodValue("Foo1"));
+        testBody(this.test1Endpoint.message(1), assertGoodValue("Foo2"));
+
+        // item 2
+        this.test2Endpoint.setExpectedCount(0);
+
+        // send
+        sendValue(this.producer1, new Variant("Foo1"));
+        sendValue(this.producer1, new Variant("Foo2"));
+
+        // assert
+        this.assertMockEndpointsSatisfied();
+    }
+
+    @Test
+    public void testWrite2() throws Exception {
+        // item 1
+        this.test1Endpoint.setExpectedCount(0);
+
+        // item 2
+        this.test2Endpoint.setExpectedCount(2);
+        testBody(this.test2Endpoint.message(0), assertGoodValue("Foo1"));
+        testBody(this.test2Endpoint.message(1), assertGoodValue("Foo2"));
+
+        // send
+        sendValue(this.producer2, new Variant("Foo1"));
+        sendValue(this.producer2, new Variant("Foo2"));
+
+        // assert
+        this.assertMockEndpointsSatisfied();
+    }
+
+    @Test
+    public void testWrite3() throws Exception {
+        // item 1
+        this.test1Endpoint.setExpectedCount(2);
+        testBody(this.test1Endpoint.message(0), assertGoodValue("Foo1"));
+        testBody(this.test1Endpoint.message(1), assertGoodValue("Foo3"));
+
+        // item 1
+        this.test2Endpoint.setExpectedCount(2);
+        testBody(this.test2Endpoint.message(0), assertGoodValue("Foo2"));
+        testBody(this.test2Endpoint.message(1), assertGoodValue("Foo4"));
+
+        // send
+        sendValue(this.producer1, new Variant("Foo1"));
+        sendValue(this.producer2, new Variant("Foo2"));
+        sendValue(this.producer3, new Variant("Foo3"));
+        sendValue(this.producer4, new Variant("Foo4"));
+
+        // assert
+        assertMockEndpointsSatisfied();
+    }
+
+    private static void sendValue(final ProducerTemplate producerTemplate, final Variant variant) {
+        // we always write synchronously since we do need the message order
+        producerTemplate.sendBodyAndHeader(variant, "await", true);
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/converter/ConverterTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/converter/ConverterTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/converter/ConverterTest.java
index 5d00ae3..93a8f78 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/converter/ConverterTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/converter/ConverterTest.java
@@ -24,26 +24,26 @@ import org.junit.Test;
 
 public class ConverterTest extends CamelTestSupport {
 
-	@Test
-	public void testDataValueToVariant() {
-		final Variant value = testConvertDataValue("Foo", Variant.class);
-		Assert.assertNotNull(value);
-		Assert.assertEquals("Foo", value.getValue());
-	}
+    @Test
+    public void testDataValueToVariant() {
+        final Variant value = testConvertDataValue("Foo", Variant.class);
+        Assert.assertNotNull(value);
+        Assert.assertEquals("Foo", value.getValue());
+    }
 
-	@Test
-	public void testVariantToDataValue() {
-		final DataValue value = testConvert(new Variant("Foo"), DataValue.class);
-		Assert.assertNotNull(value);
-		Assert.assertEquals("Foo", value.getValue().getValue());
-		Assert.assertTrue(value.getStatusCode().isGood());
-	}
+    @Test
+    public void testVariantToDataValue() {
+        final DataValue value = testConvert(new Variant("Foo"), DataValue.class);
+        Assert.assertNotNull(value);
+        Assert.assertEquals("Foo", value.getValue().getValue());
+        Assert.assertTrue(value.getStatusCode().isGood());
+    }
 
-	private <T> T testConvert(final Object value, final Class<T> clazz) {
-		return this.context.getTypeConverter().convertTo(clazz, value);
-	}
+    private <T> T testConvert(final Object value, final Class<T> clazz) {
+        return this.context.getTypeConverter().convertTo(clazz, value);
+    }
 
-	private <T> T testConvertDataValue(final Object value, final Class<T> clazz) {
-		return this.context.getTypeConverter().convertTo(clazz, new DataValue(new Variant(value)));
-	}
+    private <T> T testConvertDataValue(final Object value, final Class<T> clazz) {
+        return this.context.getTypeConverter().convertTo(clazz, new DataValue(new Variant(value)));
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerLocalTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerLocalTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerLocalTest.java
index 53b66ec..3195e18 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerLocalTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerLocalTest.java
@@ -30,54 +30,54 @@ import org.junit.Test;
  */
 public class ServerLocalTest extends CamelTestSupport {
 
-	private static final String MILO_ITEM_1 = "milo-server:myitem1";
+    private static final String MILO_ITEM_1 = "milo-server:myitem1";
 
-	private static final String MOCK_TEST = "mock:test";
+    private static final String MOCK_TEST = "mock:test";
 
-	@EndpointInject(uri = MOCK_TEST)
-	protected MockEndpoint testEndpoint;
+    @EndpointInject(uri = MOCK_TEST)
+    protected MockEndpoint testEndpoint;
 
-	@Override
-	protected RoutesBuilder createRouteBuilder() throws Exception {
-		return new RouteBuilder() {
-			@Override
-			public void configure() throws Exception {
-				from(MILO_ITEM_1).to(MOCK_TEST);
-			}
-		};
-	}
+    @Override
+    protected RoutesBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from(MILO_ITEM_1).to(MOCK_TEST);
+            }
+        };
+    }
 
-	@Test
-	public void shouldStartComponent() {
-	}
+    @Test
+    public void shouldStartComponent() {
+    }
 
-	@Test
-	public void testAcceptVariantString() {
-		sendBody(MILO_ITEM_1, new Variant("Foo"));
-	}
+    @Test
+    public void testAcceptVariantString() {
+        sendBody(MILO_ITEM_1, new Variant("Foo"));
+    }
 
-	@Test
-	public void testAcceptVariantDouble() {
-		sendBody(MILO_ITEM_1, new Variant(0.0));
-	}
+    @Test
+    public void testAcceptVariantDouble() {
+        sendBody(MILO_ITEM_1, new Variant(0.0));
+    }
 
-	@Test
-	public void testAcceptString() {
-		sendBody(MILO_ITEM_1, "Foo");
-	}
+    @Test
+    public void testAcceptString() {
+        sendBody(MILO_ITEM_1, "Foo");
+    }
 
-	@Test
-	public void testAcceptDouble() {
-		sendBody(MILO_ITEM_1, 0.0);
-	}
+    @Test
+    public void testAcceptDouble() {
+        sendBody(MILO_ITEM_1, 0.0);
+    }
 
-	@Test
-	public void testAcceptDataValueString() {
-		sendBody(MILO_ITEM_1, new DataValue(new Variant("Foo")));
-	}
+    @Test
+    public void testAcceptDataValueString() {
+        sendBody(MILO_ITEM_1, new DataValue(new Variant("Foo")));
+    }
 
-	@Test
-	public void testAcceptDataValueDouble() {
-		sendBody(MILO_ITEM_1, new DataValue(new Variant(0.0)));
-	}
+    @Test
+    public void testAcceptDataValueDouble() {
+        sendBody(MILO_ITEM_1, new DataValue(new Variant(0.0)));
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetCertificateManagerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetCertificateManagerTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetCertificateManagerTest.java
index 35f31d6..979451b 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetCertificateManagerTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetCertificateManagerTest.java
@@ -30,22 +30,21 @@ import org.junit.Test;
  */
 public class ServerSetCertificateManagerTest extends AbstractMiloServerTest {
 
-	@Override
-	protected void configureMiloServer(final MiloServerComponent server) throws Exception {
-		super.configureMiloServer(server);
+    @Override
+    protected void configureMiloServer(final MiloServerComponent server) throws Exception {
+        super.configureMiloServer(server);
 
-		final Path baseDir = Paths.get("target/testing/cert/default");
-		final Path trusted = baseDir.resolve("trusted");
+        final Path baseDir = Paths.get("target/testing/cert/default");
+        final Path trusted = baseDir.resolve("trusted");
 
-		Files.createDirectories(trusted);
-		Files.copy(Paths.get("src/test/resources/cert/certificate.der"), trusted.resolve("certificate.der"),
-				REPLACE_EXISTING);
+        Files.createDirectories(trusted);
+        Files.copy(Paths.get("src/test/resources/cert/certificate.der"), trusted.resolve("certificate.der"), REPLACE_EXISTING);
 
-		server.setServerCertificate(loadDefaultTestKey());
-		server.setDefaultCertificateValidator(baseDir.toFile());
-	}
+        server.setServerCertificate(loadDefaultTestKey());
+        server.setDefaultCertificateValidator(baseDir.toFile());
+    }
 
-	@Test
-	public void shouldStart() {
-	}
+    @Test
+    public void shouldStart() {
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetSecurityPoliciesTest.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetSecurityPoliciesTest.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetSecurityPoliciesTest.java
index 75e3457..92148aa 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetSecurityPoliciesTest.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/server/ServerSetSecurityPoliciesTest.java
@@ -24,27 +24,27 @@ import org.junit.Test;
  */
 public class ServerSetSecurityPoliciesTest extends CamelTestSupport {
 
-	@Test
-	public void testSetSecurityPolicies1() {
-		final MiloServerComponent component = new MiloServerComponent();
-		component.setSecurityPoliciesById("None");
-	}
+    @Test
+    public void testSetSecurityPolicies1() {
+        final MiloServerComponent component = new MiloServerComponent();
+        component.setSecurityPoliciesById("None");
+    }
 
-	@Test
-	public void testSetSecurityPolicies2() {
-		final MiloServerComponent component = new MiloServerComponent();
-		component.setSecurityPoliciesById("http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256");
-	}
+    @Test
+    public void testSetSecurityPolicies2() {
+        final MiloServerComponent component = new MiloServerComponent();
+        component.setSecurityPoliciesById("http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256");
+    }
 
-	@Test
-	public void testSetSecurityPolicies3() {
-		final MiloServerComponent component = new MiloServerComponent();
-		component.setSecurityPoliciesById("None", "http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256");
-	}
+    @Test
+    public void testSetSecurityPolicies3() {
+        final MiloServerComponent component = new MiloServerComponent();
+        component.setSecurityPoliciesById("None", "http://opcfoundation.org/UA/SecurityPolicy#Basic256Sha256");
+    }
 
-	@Test(expected = IllegalArgumentException.class)
-	public void testSetSecurityPolicies4() {
-		final MiloServerComponent component = new MiloServerComponent();
-		component.setSecurityPoliciesById("I just made that up");
-	}
+    @Test(expected = IllegalArgumentException.class)
+    public void testSetSecurityPolicies4() {
+        final MiloServerComponent component = new MiloServerComponent();
+        component.setSecurityPoliciesById("I just made that up");
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application.java
index 1fa5df6..e49fea9 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application.java
@@ -21,52 +21,49 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.DefaultCamelContext;
 
 public class Application {
-	public static void main(final String[] args) throws Exception {
+    public static void main(final String[] args) throws Exception {
 
-		// camel conext
+        // camel conext
 
-		final CamelContext context = new DefaultCamelContext();
+        final CamelContext context = new DefaultCamelContext();
 
-		// add paho
+        // add paho
 
-		// no need to register, gets auto detected
-		// context.addComponent("paho", new PahoComponent());
+        // no need to register, gets auto detected
+        // context.addComponent("paho", new PahoComponent());
 
-		// no need to register, gets auto detected
-		// context.addComponent("milo-server", new MiloClientComponent());
-		// context.addComponent("milo-client", new MiloClientComponent());
+        // no need to register, gets auto detected
+        // context.addComponent("milo-server", new MiloClientComponent());
+        // context.addComponent("milo-client", new MiloClientComponent());
 
-		// add routes
+        // add routes
 
-		context.addRoutes(new RouteBuilder() {
+        context.addRoutes(new RouteBuilder() {
 
-			@Override
-			public void configure() throws Exception {
-				from("paho:javaonedemo/eclipse-greenhouse-9home/sensors/temperature?brokerUrl=tcp://iot.eclipse.org:1883")
-						.log("Temp update: ${body}").convertBodyTo(String.class).to("milo-server:MyItem");
+            @Override
+            public void configure() throws Exception {
+                from("paho:javaonedemo/eclipse-greenhouse-9home/sensors/temperature?brokerUrl=tcp://iot.eclipse.org:1883").log("Temp update: ${body}").convertBodyTo(String.class)
+                    .to("milo-server:MyItem");
 
-				from("milo-server:MyItem").log("MyItem: ${body}");
+                from("milo-server:MyItem").log("MyItem: ${body}");
 
-				from("milo-server:MyItem2").log("MyItem2 : ${body}")
-						.to("paho:de/dentrassi/camel/milo/test1?brokerUrl=tcp://iot.eclipse.org:1883");
+                from("milo-server:MyItem2").log("MyItem2 : ${body}").to("paho:de/dentrassi/camel/milo/test1?brokerUrl=tcp://iot.eclipse.org:1883");
 
-				from("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem&namespaceUri=urn:camel")
-						.log("From OPC UA: ${body}")
-						.to("milo-client:tcp://localhost:12685?nodeId=items-MyItem2&namespaceUri=urn:camel");
+                from("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem&namespaceUri=urn:camel").log("From OPC UA: ${body}")
+                    .to("milo-client:tcp://localhost:12685?nodeId=items-MyItem2&namespaceUri=urn:camel");
 
-				from("paho:de/dentrassi/camel/milo/test1?brokerUrl=tcp://iot.eclipse.org:1883")
-						.log("Back from MQTT: ${body}");
-			}
-		});
+                from("paho:de/dentrassi/camel/milo/test1?brokerUrl=tcp://iot.eclipse.org:1883").log("Back from MQTT: ${body}");
+            }
+        });
 
-		// start
+        // start
 
-		context.start();
+        context.start();
 
-		// sleep
+        // sleep
 
-		while (true) {
-			Thread.sleep(Long.MAX_VALUE);
-		}
-	}
+        while (true) {
+            Thread.sleep(Long.MAX_VALUE);
+        }
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Client.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Client.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Client.java
index 4d76b38..3f03789 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Client.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Client.java
@@ -21,39 +21,38 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.DefaultCamelContext;
 
 public class Application2Client {
-	public static void main(final String[] args) throws Exception {
+    public static void main(final String[] args) throws Exception {
 
-		// camel conext
+        // camel conext
 
-		final CamelContext context = new DefaultCamelContext();
+        final CamelContext context = new DefaultCamelContext();
 
-		// add paho
+        // add paho
 
-		// no need to register, gets auto detected
-		// context.addComponent("paho", new PahoComponent());
+        // no need to register, gets auto detected
+        // context.addComponent("paho", new PahoComponent());
 
-		// add OPC UA
+        // add OPC UA
 
-		// add routes
+        // add routes
 
-		context.addRoutes(new RouteBuilder() {
+        context.addRoutes(new RouteBuilder() {
 
-			@Override
-			public void configure() throws Exception {
-				from("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem&namespaceUri=urn:org:apache:camel")
-						.log("From OPC UA: ${body}")
-						.to("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem2&namespaceUri=urn:org:apache:camel");
-			}
-		});
+            @Override
+            public void configure() throws Exception {
+                from("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem&namespaceUri=urn:org:apache:camel").log("From OPC UA: ${body}")
+                    .to("milo-client:tcp://foo:bar@localhost:12685?nodeId=items-MyItem2&namespaceUri=urn:org:apache:camel");
+            }
+        });
 
-		// start
+        // start
 
-		context.start();
+        context.start();
 
-		// sleep
+        // sleep
 
-		while (true) {
-			Thread.sleep(Long.MAX_VALUE);
-		}
-	}
+        while (true) {
+            Thread.sleep(Long.MAX_VALUE);
+        }
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/19db14d7/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Server.java
----------------------------------------------------------------------
diff --git a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Server.java b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Server.java
index af596cf..21d955e 100644
--- a/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Server.java
+++ b/components/camel-milo/src/test/java/org/apache/camel/component/milo/testing/Application2Server.java
@@ -22,51 +22,48 @@ import org.apache.camel.component.milo.server.MiloServerComponent;
 import org.apache.camel.impl.DefaultCamelContext;
 
 public class Application2Server {
-	public static void main(final String[] args) throws Exception {
+    public static void main(final String[] args) throws Exception {
 
-		// camel conext
+        // camel conext
 
-		final CamelContext context = new DefaultCamelContext();
+        final CamelContext context = new DefaultCamelContext();
 
-		// add paho
+        // add paho
 
-		// no need to register, gets auto detected
-		// context.addComponent("paho", new PahoComponent());
-		((MiloServerComponent) context.getComponent("milo-server")).setUserAuthenticationCredentials("foo:bar");
+        // no need to register, gets auto detected
+        // context.addComponent("paho", new PahoComponent());
+        ((MiloServerComponent)context.getComponent("milo-server")).setUserAuthenticationCredentials("foo:bar");
 
-		// add routes
+        // add routes
 
-		context.addRoutes(new RouteBuilder() {
+        context.addRoutes(new RouteBuilder() {
 
-			@Override
-			public void configure() throws Exception {
-				/*
-				 * from(
-				 * "paho:javaonedemo/eclipse-greenhouse-9home/sensors/temperature?brokerUrl=tcp://iot.eclipse.org:1883")
-				 * .log("Temp update: ${body}").convertBodyTo(String.class).to(
-				 * "milo-server:MyItem");
-				 */
+            @Override
+            public void configure() throws Exception {
+                /*
+                 * from(
+                 * "paho:javaonedemo/eclipse-greenhouse-9home/sensors/temperature?brokerUrl=tcp://iot.eclipse.org:1883")
+                 * .log("Temp update: ${body}").convertBodyTo(String.class).to(
+                 * "milo-server:MyItem");
+                 */
 
-				from("paho:my/foo/bar?brokerUrl=tcp://iot.eclipse.org:1883").log("Temp update: ${body}")
-						.convertBodyTo(String.class).to("milo-server:MyItem");
+                from("paho:my/foo/bar?brokerUrl=tcp://iot.eclipse.org:1883").log("Temp update: ${body}").convertBodyTo(String.class).to("milo-server:MyItem");
 
-				from("milo-server:MyItem").log("MyItem: ${body}");
-				from("milo-server:MyItem2").log("MyItem2: ${body}").convertBodyTo(String.class)
-						.to("paho:de/dentrassi/camel/milo/temperature?brokerUrl=tcp://iot.eclipse.org:1883");
+                from("milo-server:MyItem").log("MyItem: ${body}");
+                from("milo-server:MyItem2").log("MyItem2: ${body}").convertBodyTo(String.class).to("paho:de/dentrassi/camel/milo/temperature?brokerUrl=tcp://iot.eclipse.org:1883");
 
-				from("paho:de/dentrassi/camel/milo/temperature?brokerUrl=tcp://iot.eclipse.org:1883")
-						.log("Back from MQTT: ${body}");
-			}
-		});
+                from("paho:de/dentrassi/camel/milo/temperature?brokerUrl=tcp://iot.eclipse.org:1883").log("Back from MQTT: ${body}");
+            }
+        });
 
-		// start
+        // start
 
-		context.start();
+        context.start();
 
-		// sleep
+        // sleep
 
-		while (true) {
-			Thread.sleep(Long.MAX_VALUE);
-		}
-	}
+        while (true) {
+            Thread.sleep(Long.MAX_VALUE);
+        }
+    }
 }


Mime
View raw message