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 2021/04/15 12:46:25 UTC
[camel] branch master updated: CAMEL-16505: Fixed camel-pulsar tests
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 d9c0fd7 CAMEL-16505: Fixed camel-pulsar tests
d9c0fd7 is described below
commit d9c0fd7f02dde551128a2110ba534dc2e20a6a46
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Apr 15 14:45:55 2021 +0200
CAMEL-16505: Fixed camel-pulsar tests
---
.../component/pulsar/PulsarConsumerDeadLetterPolicyTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerDeadLetterPolicyTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerDeadLetterPolicyTest.java
index 8420d99..0ec9299 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerDeadLetterPolicyTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerDeadLetterPolicyTest.java
@@ -117,7 +117,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport {
+ "?maxRedeliverCount=5&subscriptionType=Shared&allowManualAcknowledgement=true&ackTimeoutMillis=1000");
PulsarEndpoint deadLetterFrom = (PulsarEndpoint) component.createEndpoint("pulsar:" + topicUri + "-subs-DLQ");
- to.expectedMessageCount(5);
+ to.expectedMessageCount(6);
deadLetter.expectedMessageCount(1);
context.addRoutes(new RouteBuilder() {
@Override
@@ -129,7 +129,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport {
});
producer.send("Hello World!");
- assertMockEndpointsSatisfied(10, TimeUnit.SECONDS);
+ assertMockEndpointsSatisfied(30, TimeUnit.SECONDS);
}
@Test
@@ -143,7 +143,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport {
PulsarEndpoint deadLetterFrom
= (PulsarEndpoint) component.createEndpoint("pulsar:persistent://public/default/customTopic");
- to.expectedMessageCount(5);
+ to.expectedMessageCount(6);
deadLetter.expectedMessageCount(1);
context.addRoutes(new RouteBuilder() {
@Override
@@ -155,7 +155,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport {
});
producer.send("Hello World!");
- assertMockEndpointsSatisfied(10, TimeUnit.SECONDS);
+ assertMockEndpointsSatisfied(30, TimeUnit.SECONDS);
}
@Test
@@ -188,7 +188,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport {
});
producer.send("Hello World!");
- assertMockEndpointsSatisfied(10, TimeUnit.SECONDS);
+ assertMockEndpointsSatisfied(30, TimeUnit.SECONDS);
}
private PulsarClient givenPulsarClient() throws PulsarClientException {