You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/01/03 08:14:26 UTC
[camel] 01/02: Polished test
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit c60bcb387c5067b6eadf9eb1cb8a23c8da2a9d77
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 3 09:02:14 2020 +0100
Polished test
---
.../test/java/org/apache/camel/component/nsq/NsqProducerTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
index db42bcf..7291fbe 100644
--- a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
+++ b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
@@ -46,13 +46,13 @@ public class NsqProducerTest extends NsqTestSupport {
counter.incrementAndGet();
message.finished();
lock.countDown();
- assertTrue(new String(message.getMessage()).equals(TEST_MESSAGE));
+ assertEquals(TEST_MESSAGE, new String(message.getMessage()));
});
consumer.start();
lock.await(30, TimeUnit.SECONDS);
- assertTrue(counter.get() == Long.valueOf(1));
+ assertEquals(1, counter.get());
consumer.shutdown();
}
@@ -73,13 +73,13 @@ public class NsqProducerTest extends NsqTestSupport {
counter.incrementAndGet();
message.finished();
lock.countDown();
- assertTrue(message.getAttempts() == 1);
+ assertEquals(1, message.getAttempts());
});
consumer.start();
lock.await(30, TimeUnit.SECONDS);
- assertTrue(counter.get() == Long.valueOf(NUMBER_OF_MESSAGES));
+ assertEquals(NUMBER_OF_MESSAGES, counter.get());
consumer.shutdown();
}