[camel] branch main updated: (chores) camel-pulsar: reduce exposure to internal Pulsar details in tests

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 2ba1763cb12 (chores) camel-pulsar: reduce exposure to internal Pulsar 
details in tests
2ba1763cb12 is described below

commit 2ba1763cb12c542f1bb79778737a0fff34990926
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Thu Jan 19 10:31:41 2023 +0100

    (chores) camel-pulsar: reduce exposure to internal Pulsar details in tests
---
 .../apache/camel/component/pulsar/integration/PulsarProducerInIT.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java
 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java
index 8790d8f8c0d..29bc8f83b28 100644
--- 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java
+++ 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java
@@ -35,7 +35,6 @@ import org.apache.pulsar.client.api.PulsarClientException;
 import org.apache.pulsar.client.impl.ClientBuilderImpl;
 import org.junit.jupiter.api.Test;
 
-import static 
org.apache.pulsar.client.api.PulsarClientException.InvalidMessageException;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
@@ -122,7 +121,7 @@ public class PulsarProducerInIT extends PulsarITSupport {
     public void testLargeMessageWithChunkingDisabled() {
         Throwable e = assertThrows(CamelExecutionException.class,
                 () -> producerTemplate.sendBody(new byte[10 * 1024 * 1024]));
-        assertTrue(ExceptionUtils.getThrowableList(e).stream().anyMatch(ex -> 
ex instanceof InvalidMessageException));
+        assertTrue(ExceptionUtils.getThrowableList(e).stream().anyMatch(ex -> 
ex instanceof PulsarClientException));
     }
 
     @Test