You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/12/12 13:57:56 UTC
[camel] 03/03: Fixed CS in NATS test
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 <an...@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);