This is an automated email from the ASF dual-hosted git repository. orpiske 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 50009e8 CAMEL-16400: split unit and integration tests for camel-pulsar (#5381) 50009e8 is described below commit 50009e87679348d4de02399327023baab585e424 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Thu Apr 15 21:08:14 2021 +0200 CAMEL-16400: split unit and integration tests for camel-pulsar (#5381) --- components/camel-pulsar/pom.xml | 69 ++-------------------- .../PulsarConcurrentConsumerInIT.java} | 7 ++- .../PulsarConcurrentProducerInIT.java} | 5 +- .../PulsarConsumerDeadLetterPolicyIT.java} | 11 ++-- .../PulsarConsumerInAsynchronousIT.java} | 8 ++- .../PulsarConsumerInIT.java} | 7 ++- .../PulsarConsumerNoAcknowledgementIT.java} | 5 +- .../PulsarConsumerPatternInIT.java} | 7 ++- .../PulsarConsumerReadCompactedIT.java} | 8 ++- .../PulsarCustomMessageReceiptIT.java} | 9 ++- .../PulsarITSupport.java} | 4 +- .../PulsarProducerHeadersInIT.java} | 5 +- .../PulsarProducerInIT.java} | 5 +- .../PulsarProducerUndefinedProducerNameInIT.java} | 5 +- 14 files changed, 56 insertions(+), 99 deletions(-) diff --git a/components/camel-pulsar/pom.xml b/components/camel-pulsar/pom.xml index f9d21d7..1283d5c 100644 --- a/components/camel-pulsar/pom.xml +++ b/components/camel-pulsar/pom.xml @@ -102,71 +102,10 @@ <forkedProcessTimeoutInSeconds>600</forkedProcessTimeoutInSeconds> </configuration> </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-failsafe-plugin</artifactId> + </plugin> </plugins> </build> - - <profiles> - <profile> - <id>pulsar-skip-tests</id> - <activation> - <activeByDefault>true</activeByDefault> - </activation> - <build> - <plugins> - <plugin> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <skipTests>true</skipTests> - </configuration> - </plugin> - </plugins> - </build> - </profile> - - <!-- activate test if the docker socket file is accessible --> - <profile> - <id>pulsar-tests-docker-file</id> - <activation> - <file> - <exists>/var/run/docker.sock</exists> - </file> - </activation> - <build> - <plugins> - <plugin> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <skipTests>${skipTests}</skipTests> - <systemPropertyVariables> - <visibleassertions.silence>true</visibleassertions.silence> - </systemPropertyVariables> - </configuration> - </plugin> - </plugins> - </build> - </profile> - - <!-- activate test if the DOCKER_HOST env var is set --> - <profile> - <id>pulsar-tests-docker-env</id> - <activation> - <property> - <name>env.DOCKER_HOST</name> - </property> - </activation> - <build> - <plugins> - <plugin> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <skipTests>${skipTests}</skipTests> - <systemPropertyVariables> - <visibleassertions.silence>true</visibleassertions.silence> - </systemPropertyVariables> - </configuration> - </plugin> - </plugins> - </build> - </profile> - </profiles> </project> 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/integration/PulsarConcurrentConsumerInIT.java similarity index 94% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConcurrentConsumerInIT.java index 4d3cecb..d9d9568 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/integration/PulsarConcurrentConsumerInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -24,6 +24,7 @@ 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; @@ -36,9 +37,9 @@ import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class PulsarConcurrentConsumerInTest extends PulsarTestSupport { +public class PulsarConcurrentConsumerInIT extends PulsarITSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConcurrentConsumerInTest.class); + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConcurrentConsumerInIT.class); private static final String TOPIC_URI = "non-persistent://public/default/concurrent-camel-topic"; private static final String PRODUCER = "camel-producer"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentProducerInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConcurrentProducerInIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentProducerInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConcurrentProducerInIT.java index 4fbcd7e..d03caf6 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentProducerInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConcurrentProducerInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -26,6 +26,7 @@ import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; 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; @@ -34,7 +35,7 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.impl.ClientBuilderImpl; import org.junit.jupiter.api.Test; -public class PulsarConcurrentProducerInTest extends PulsarTestSupport { +public class PulsarConcurrentProducerInIT extends PulsarITSupport { private static final String TOPIC_URI = "persistent://public/default/camel-concurrent-producers-topic"; private static final String PRODUCER = "camel-producer"; 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/integration/PulsarConsumerDeadLetterPolicyIT.java similarity index 94% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerDeadLetterPolicyTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerDeadLetterPolicyIT.java index 0ec9299..2d45cb4 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/integration/PulsarConsumerDeadLetterPolicyIT.java @@ -14,13 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; import org.apache.camel.EndpointInject; 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.PulsarEndpoint; +import org.apache.camel.component.pulsar.PulsarMessageReceipt; import org.apache.camel.component.pulsar.utils.AutoConfiguration; import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders; import org.apache.camel.spi.Registry; @@ -39,8 +42,8 @@ import org.slf4j.LoggerFactory; import static org.junit.jupiter.api.Assertions.assertNull; -public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerDeadLetterPolicyTest.class); +public class PulsarConsumerDeadLetterPolicyIT extends PulsarITSupport { + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerDeadLetterPolicyIT.class); private static final String TOPIC_URI = "persistent://public/default/camel-topic-"; private static int topicId; @@ -84,7 +87,7 @@ public class PulsarConsumerDeadLetterPolicyTest extends PulsarTestSupport { } String producerName = this.getClass().getSimpleName() + TestUtils.randomWithRange(1, 100); - topicUri = PulsarConsumerDeadLetterPolicyTest.TOPIC_URI + ++topicId; + topicUri = PulsarConsumerDeadLetterPolicyIT.TOPIC_URI + ++topicId; producer = givenPulsarClient().newProducer(Schema.STRING).producerName(producerName).topic(topicUri).create(); } diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java similarity index 96% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java index 7eb5886..0d4096f 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInAsynchronousIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; @@ -25,6 +25,8 @@ 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.PulsarMessageReceipt; import org.apache.camel.component.pulsar.utils.AutoConfiguration; import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders; import org.apache.camel.spi.Registry; @@ -40,9 +42,9 @@ import org.slf4j.LoggerFactory; import static org.apache.camel.test.junit5.TestSupport.body; -public class PulsarConsumerInAsynchronousTest extends PulsarTestSupport { +public class PulsarConsumerInAsynchronousIT extends PulsarITSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInAsynchronousTest.class); + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInAsynchronousIT.class); private static final String TOPIC_URI_SYNCHRONOUS_FALSE = "persistent://public/default/synchronousFalse"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInIT.java index ea94116..5f82668 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -24,6 +24,7 @@ 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; @@ -36,9 +37,9 @@ import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class PulsarConsumerInTest extends PulsarTestSupport { +public class PulsarConsumerInIT extends PulsarITSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInTest.class); + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInIT.class); private static final String TOPIC_URI = "persistent://public/default/camel-topic"; private static final String PRODUCER = "camel-producer-1"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerNoAcknowledgementIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerNoAcknowledgementIT.java index 07260b6..026e0d2 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerNoAcknowledgementIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -22,6 +22,7 @@ import org.apache.camel.Endpoint; import org.apache.camel.EndpointInject; 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; @@ -32,7 +33,7 @@ import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.impl.ClientBuilderImpl; import org.junit.jupiter.api.Test; -public class PulsarConsumerNoAcknowledgementTest extends PulsarTestSupport { +public class PulsarConsumerNoAcknowledgementIT extends PulsarITSupport { private static final String TOPIC_URI = "persistent://public/default/camel-topic"; private static final String PRODUCER = "camel-producer-1"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerPatternInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerPatternInIT.java similarity index 96% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerPatternInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerPatternInIT.java index 8b5d82b..5c77617 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerPatternInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerPatternInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -22,6 +22,7 @@ import org.apache.camel.Endpoint; import org.apache.camel.EndpointInject; 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; @@ -36,9 +37,9 @@ import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class PulsarConsumerPatternInTest extends PulsarTestSupport { +public class PulsarConsumerPatternInIT extends PulsarITSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerPatternInTest.class); + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerPatternInIT.class); private static final String TOPIC_URI = "persistent://public/default/camel-foo"; private static final String TOPIC_TWO_URI = "persistent://public/default/camel-bar"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerReadCompactedIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerReadCompactedIT.java index a219724..bed5c4f 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarConsumerReadCompactedIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -23,6 +23,8 @@ import org.apache.camel.Endpoint; import org.apache.camel.EndpointInject; 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.PulsarMessageReceipt; import org.apache.camel.component.pulsar.utils.AutoConfiguration; import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders; import org.apache.camel.spi.Registry; @@ -44,8 +46,8 @@ import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class PulsarConsumerReadCompactedTest extends PulsarTestSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerReadCompactedTest.class); +public class PulsarConsumerReadCompactedIT extends PulsarITSupport { + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerReadCompactedIT.class); private static final String TOPIC_URI = "persistent://public/default/camel-topic"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarCustomMessageReceiptIT.java similarity index 93% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarCustomMessageReceiptIT.java index 8ca5a46..68c93c3 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarCustomMessageReceiptIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -22,6 +22,9 @@ import org.apache.camel.Endpoint; import org.apache.camel.EndpointInject; 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.PulsarMessageReceipt; +import org.apache.camel.component.pulsar.PulsarMessageReceiptFactory; import org.apache.camel.component.pulsar.utils.AutoConfiguration; import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders; import org.apache.camel.spi.Registry; @@ -43,9 +46,9 @@ import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; -public class PulsarCustomMessageReceiptTest extends PulsarTestSupport { +public class PulsarCustomMessageReceiptIT extends PulsarITSupport { - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarCustomMessageReceiptTest.class); + private static final Logger LOGGER = LoggerFactory.getLogger(PulsarCustomMessageReceiptIT.class); private static final String TOPIC_URI = "persistent://public/default/camel-topic"; private static final String PRODUCER = "camel-producer-1"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarITSupport.java similarity index 92% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarITSupport.java index 9503f3a..d5b4d8f 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarTestSupport.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarITSupport.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import org.apache.camel.test.infra.pulsar.services.PulsarService; import org.apache.camel.test.infra.pulsar.services.PulsarServiceFactory; import org.apache.camel.test.junit5.CamelTestSupport; import org.junit.jupiter.api.extension.RegisterExtension; -public class PulsarTestSupport extends CamelTestSupport { +public class PulsarITSupport extends CamelTestSupport { @RegisterExtension static PulsarService service = PulsarServiceFactory.createService(); diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerHeadersInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerHeadersInIT.java similarity index 96% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerHeadersInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerHeadersInIT.java index 869a13a..33231f1 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerHeadersInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerHeadersInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.HashMap; import java.util.Map; @@ -26,6 +26,7 @@ import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; 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.component.pulsar.utils.message.PulsarMessageHeaders; import org.apache.camel.spi.Registry; @@ -35,7 +36,7 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.impl.ClientBuilderImpl; import org.junit.jupiter.api.Test; -public class PulsarProducerHeadersInTest extends PulsarTestSupport { +public class PulsarProducerHeadersInIT extends PulsarITSupport { private static final String TOPIC_URI = "persistent://public/default/camel-producer-topic"; private static final String PRODUCER = "camel-producer"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java index affd26b..77c1ae5 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -24,6 +24,7 @@ import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; 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; @@ -32,7 +33,7 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.impl.ClientBuilderImpl; import org.junit.jupiter.api.Test; -public class PulsarProducerInTest extends PulsarTestSupport { +public class PulsarProducerInIT extends PulsarITSupport { private static final String TOPIC_URI = "persistent://public/default/camel-producer-topic"; private static final String PRODUCER = "camel-producer"; diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerUndefinedProducerNameInTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerUndefinedProducerNameInIT.java similarity index 95% rename from components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerUndefinedProducerNameInTest.java rename to components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerUndefinedProducerNameInIT.java index b7d8176..ceef570 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerUndefinedProducerNameInTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarProducerUndefinedProducerNameInIT.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.camel.component.pulsar; +package org.apache.camel.component.pulsar.integration; import java.util.concurrent.TimeUnit; @@ -24,6 +24,7 @@ import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; 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; @@ -32,7 +33,7 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.impl.ClientBuilderImpl; import org.junit.jupiter.api.Test; -public class PulsarProducerUndefinedProducerNameInTest extends PulsarTestSupport { +public class PulsarProducerUndefinedProducerNameInIT extends PulsarITSupport { private static final String TOPIC_URI = "persistent://public/default/camel-producer-topic";