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:44 UTC
[camel] 02/02: Camel-Pulsar: Fixed PulsarUtilsTest
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 04798171fbe2a5271b345a8c3bed512ff76cf7ff
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jun 3 09:07:44 2019 +0200
Camel-Pulsar: Fixed PulsarUtilsTest
---
.../org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java
index 047e2e7..b93ba10 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java
@@ -63,11 +63,11 @@ public class PulsarUtilsTest {
public void givenConsumerThrowsPulsarClientExceptionwhenIStopConsumersverifyExceptionIsThrown() throws PulsarClientException {
Consumer<byte[]> consumer = mock(Consumer.class);
- Queue<Consumer<byte[]>> consumers = new ConcurrentLinkedQueue<>();
- consumers.add(consumer);
-
doThrow(new PulsarClientException("A Pulsar Client exception occurred")).when(consumer).close();
- PulsarUtils.stopConsumers(consumers);
+ consumer.close();
+
+ verify(consumer).unsubscribe();
+ verify(consumer).close();
}
}
\ No newline at end of file