Skip to content

Commit

Permalink
(chores) Cleanup unused annotations
Browse files Browse the repository at this point in the history
  • Loading branch information
orpiske committed Jan 19, 2021
1 parent e1d54c1 commit 062a02c
Show file tree
Hide file tree
Showing 15 changed files with 0 additions and 30 deletions.
Expand Up @@ -40,13 +40,11 @@
import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@Testcontainers
public class CamelSinkHTTPITCase extends AbstractKafkaTest {
private static final Logger LOG = LoggerFactory.getLogger(CamelSinkHTTPITCase.class);
private static final int HTTP_PORT = NetworkUtils.getFreePort("localhost");
Expand Down
Expand Up @@ -43,14 +43,12 @@
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.JdbcDatabaseContainer;
import org.testcontainers.containers.PostgreSQLContainer;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@Testcontainers
public class CamelSinkJDBCITCase extends AbstractKafkaTest {
@RegisterExtension
static JDBCService jdbcService;
Expand Down
Expand Up @@ -42,14 +42,12 @@
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.JdbcDatabaseContainer;
import org.testcontainers.containers.PostgreSQLContainer;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@Testcontainers
public class CamelSinkJDBCNoDataSourceITCase extends AbstractKafkaTest {
@RegisterExtension
static JDBCService jdbcService;
Expand Down
Expand Up @@ -44,15 +44,13 @@
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;

/**
* Integration tests for the JMS sink
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSinkJMSITCase extends AbstractKafkaTest {
@RegisterExtension
Expand Down
Expand Up @@ -32,7 +32,6 @@
import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
Expand All @@ -41,7 +40,6 @@
* Integration tests for the JMS sink with a DLQ configuration. This test forces a failure in the sink connector to
* ensure that the failed records are added to the DLQ configured in Kafka.
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSinkWithDLQJMSITCase extends AbstractKafkaTest {
private static final Logger LOG = LoggerFactory.getLogger(CamelSinkWithDLQJMSITCase.class);
Expand Down
Expand Up @@ -37,7 +37,6 @@
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
Expand All @@ -47,7 +46,6 @@
* A simple test case that checks whether the timer produces the expected number of
* messages
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSourceJMSITCase extends AbstractKafkaTest {
@RegisterExtension
Expand Down
Expand Up @@ -28,14 +28,12 @@
import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.fail;

/**
* Integration tests for the JMS sink
*/
@Testcontainers
/* This test is disabled by default because requires manual verification on Slack end.
You need to set 3 system properties to run this test:
Expand Down
Expand Up @@ -29,12 +29,10 @@
import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

@Testcontainers

/*
This test is disabled by default because requires manual steps.
Expand Down
Expand Up @@ -42,13 +42,11 @@
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.JdbcDatabaseContainer;
import org.testcontainers.containers.PostgreSQLContainer;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;

@Testcontainers
public class CamelSinkSQLITCase extends AbstractKafkaTest {
private static final Logger LOG = LoggerFactory.getLogger(CamelSinkSQLITCase.class);

Expand Down
Expand Up @@ -35,13 +35,11 @@
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.JdbcDatabaseContainer;
import org.testcontainers.containers.PostgreSQLContainer;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;

@DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-(kafka|strimzi)-container",
disabledReason = "Database connection fails when running with the embedded Kafka Connect instance")
@Testcontainers
public class CamelSourceSQLITCase extends AbstractKafkaTest {
private static final Logger LOG = LoggerFactory.getLogger(CamelSourceSQLITCase.class);

Expand Down
Expand Up @@ -35,13 +35,11 @@
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.fail;

@DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-(kafka|strimzi)-container",
disabledReason = "Hangs when running with the embedded Kafka Connect instance")
@Testcontainers
public class CamelSinkSshITCase extends AbstractKafkaTest {
@RegisterExtension
public static SshService sshService = SshServiceFactory.createService();
Expand Down
Expand Up @@ -29,7 +29,6 @@
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
Expand All @@ -39,7 +38,6 @@
* A simple test case that checks whether the syslog send the expected number of
* messages
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSinkSyslogITCase extends AbstractKafkaTest {
private static final int FREE_PORT = NetworkUtils.getFreePort("localhost", NetworkUtils.Protocol.UDP);
Expand Down
Expand Up @@ -34,7 +34,6 @@
import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
Expand All @@ -44,7 +43,6 @@
* A simple test case that checks whether the timer produces the expected number of
* messages
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSourceSyslogITCase extends AbstractKafkaTest {
private static final int FREE_PORT = NetworkUtils.getFreePort("localhost", NetworkUtils.Protocol.UDP);
Expand Down
Expand Up @@ -30,15 +30,13 @@
import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.junit.jupiter.Testcontainers;

import static org.junit.jupiter.api.Assertions.assertEquals;

/**
* A simple test case that checks whether the timer produces the expected number of
* messages
*/
@Testcontainers
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class CamelSourceTimerITCase extends AbstractKafkaTest {
private static final Logger LOG = LoggerFactory.getLogger(CamelSourceTimerITCase.class);
Expand Down
Expand Up @@ -29,9 +29,7 @@
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.testcontainers.junit.jupiter.Testcontainers;

@Testcontainers
@EnabledIfSystemProperty(named = "it.test.perf.enabled", matches = "true")
public class RabbitMQSourcePerformanceITCase extends AbstractKafkaTest {
@RegisterExtension
Expand Down

0 comments on commit 062a02c

Please sign in to comment.