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 2021/08/24 11:41:40 UTC
[camel] 03/03: CAMEL-16392 - Added some tests
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5acd7a1bc17cd478454ee349db6afac08942ce01
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Aug 24 13:40:57 2021 +0200
CAMEL-16392 - Added some tests
---
.../pulsar/integration/PulsarConsumerInURIClientIT.java | 12 ++++--------
1 file changed, 4 insertions(+), 8 deletions(-)
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInURIClientIT.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInURIClientIT.java
index c82f4bc..a776b7f 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInURIClientIT.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInURIClientIT.java
@@ -16,16 +16,13 @@
*/
package org.apache.camel.component.pulsar.integration;
-import org.apache.camel.Endpoint;
+import java.util.concurrent.TimeUnit;
+
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.component.pulsar.PulsarComponent;
-import org.apache.camel.component.pulsar.utils.AutoConfiguration;
-import org.apache.camel.spi.Registry;
-import org.apache.camel.support.SimpleRegistry;
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
@@ -35,8 +32,6 @@ import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.concurrent.TimeUnit;
-
public class PulsarConsumerInURIClientIT extends PulsarITSupport {
private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInURIClientIT.class);
@@ -44,7 +39,8 @@ public class PulsarConsumerInURIClientIT extends PulsarITSupport {
private static final String TOPIC_URI = "persistent://public/default/camel-topic";
private static final String PRODUCER = "camel-producer-1";
private static final String URI_ENDPOINT = "pulsar:" + TOPIC_URI + "?numberOfConsumers=1&subscriptionType=Exclusive"
- + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer&serviceUrl=" + service.getPulsarBrokerUrl();
+ + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer&serviceUrl="
+ + service.getPulsarBrokerUrl();
@EndpointInject("mock:result")
private MockEndpoint to;