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
The following commit(s) were added to refs/heads/master by this push:
new 1b336a9 Polished
1b336a9 is described below
commit 1b336a9b622d5a5f1af77b109b2f48ffb98e812a
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Feb 15 09:32:40 2020 +0100
Polished
---
.../src/test/java/org/apache/camel/component/nsq/NsqConsumerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqConsumerTest.java
b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqConsumerTest.java
index 2c20e87..48197bb 100644
---
a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqConsumerTest.java
+++
b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqConsumerTest.java
@@ -92,7 +92,7 @@ public class NsqConsumerTest extends NsqTestSupport {
String messageText =
exchange.getIn().getBody(String.class);
int attempts =
exchange.getIn().getHeader(NsqConstants.NSQ_MESSAGE_ATTEMPTS, Integer.class);
if (messageText.contains("Requeue") && attempts < 3) {
- throw new Exception();
+ throw new Exception("Forced error");
}
}
}).to(mockResultEndpoint);