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 2019/06/03 07:09:43 UTC
[camel] 01/02: Camel-Pulsar: Fixed concurrent consumers test
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6e4943ae3ed462faadda268f20c12cf5e5b75e4d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jun 3 09:00:40 2019 +0200
Camel-Pulsar: Fixed concurrent consumers test
---
.../apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java
index dcd3a02..1d25f25 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java
@@ -90,12 +90,12 @@ public class PulsarConcurrentConsumerInTest extends PulsarTestSupport {
}
private PulsarClient concurrentPulsarClient() throws PulsarClientException {
- return new ClientBuilderImpl().serviceUrl(getPulsarBrokerUrl()).ioThreads(2).listenerThreads(5).build();
+ return new ClientBuilderImpl().serviceUrl(getPulsarBrokerUrl()).ioThreads(5).listenerThreads(5).build();
}
@Test
public void testMultipleMessageConsumedByClusterwithConcurrentConfiguration() throws Exception {
- to.expectedMessageCount(NUMBER_OF_CONSUMERS);
+ to.expectedMinimumMessageCount(1);
Producer<String> producer = concurrentPulsarClient().newProducer(Schema.STRING).producerName(PRODUCER).topic(TOPIC_URI).create();