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

acosentino pushed a commit to branch sandbox/camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 1cc299a6b17d8393063a9fccea34d0238f59f7ee
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Dec 12 14:48:39 2018 +0100

    Fixed CS in NATS test
---
 .../camel/component/nats/NatsConsumerWithRedeliveryTest.java       | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithRedeliveryTest.java
 
b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithRedeliveryTest.java
index cac5149..0c8cf88 100644
--- 
a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithRedeliveryTest.java
+++ 
b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithRedeliveryTest.java
@@ -18,6 +18,8 @@ package org.apache.camel.component.nats;
 
 import java.io.IOException;
 
+import io.nats.client.Message;
+
 import org.apache.camel.EndpointInject;
 import org.apache.camel.Exchange;
 import org.apache.camel.LoggingLevel;
@@ -27,8 +29,6 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.junit.Test;
 
-import io.nats.client.Message;
-
 public class NatsConsumerWithRedeliveryTest extends NatsTestSupport {
 
     private static final int REDELIVERY_COUNT = 2;
@@ -69,8 +69,9 @@ public class NatsConsumerWithRedeliveryTest extends 
NatsTestSupport {
                     public boolean matches(Exchange exchange) {
                         Message g = exchange.getIn().getBody(Message.class);
                         String s = new String(g.getData());
-                        if (s.contains("test"))
+                        if (s.contains("test")) {
                             return true;
+                        }
                         return false;
                     }
                 }).throwException(RuntimeCamelException.class, "Test for 
this").end().to(mockResultEndpoint);

Reply via email to