This is an automated email from the ASF dual-hosted git repository. gnodet pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 63cfacedecc482b88a883e5c372e8cc7180270c7 Author: Guillaume Nodet <gno...@gmail.com> AuthorDate: Fri Jul 24 12:03:29 2020 +0200 [CAMEL-11807] Upgrade camel-thrift to junit5 --- components/camel-thrift/pom.xml | 6 +++--- .../component/thrift/ThriftConsumerAsyncTest.java | 16 ++++++++++------ .../thrift/ThriftConsumerConcurrentTest.java | 11 +++++++---- .../thrift/ThriftConsumerSecurityTest.java | 16 ++++++++++------ .../component/thrift/ThriftConsumerSyncTest.java | 16 ++++++++++------ .../thrift/ThriftConsumerZlibCompressionTest.java | 16 ++++++++++------ .../component/thrift/ThriftProducerAsyncTest.java | 9 +++++++-- .../component/thrift/ThriftProducerBaseTest.java | 10 +++++----- .../thrift/ThriftProducerSecurityTest.java | 22 ++++++++++++++-------- .../component/thrift/ThriftProducerSyncTest.java | 12 +++++++++--- .../thrift/ThriftProducerZlibCompressionTest.java | 17 +++++++++++------ .../thrift/local/ThriftThreadPoolServerTest.java | 14 ++++++++------ .../thrift/ThriftMarshalAndUnmarshalJsonTest.java | 6 ++++-- .../ThriftMarshalAndUnmarshalSpringTest.java | 10 +++++++--- .../thrift/ThriftMarshalAndUnmarshalTest.java | 10 +++++++--- 15 files changed, 122 insertions(+), 69 deletions(-) diff --git a/components/camel-thrift/pom.xml b/components/camel-thrift/pom.xml index d0747f3..571145e 100644 --- a/components/camel-thrift/pom.xml +++ b/components/camel-thrift/pom.xml @@ -61,12 +61,12 @@ <!-- testing --> <dependency> <groupId>org.apache.camel</groupId> - <artifactId>camel-test-spring</artifactId> + <artifactId>camel-test-spring-junit5</artifactId> <scope>test</scope> </dependency> <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> + <groupId>org.junit.jupiter</groupId> + <artifactId>junit-jupiter</artifactId> <scope>test</scope> </dependency> <dependency> diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerAsyncTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerAsyncTest.java index 5fc1b58..1dea8f6 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerAsyncTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerAsyncTest.java @@ -30,19 +30,23 @@ import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.async.AsyncMethodCallback; import org.apache.thrift.async.TAsyncClientManager; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.transport.TNonblockingSocket; import org.apache.thrift.transport.TNonblockingTransport; import org.apache.thrift.transport.TTransportException; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftConsumerAsyncTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftConsumerAsyncTest.class); private static final int THRIFT_TEST_PORT = AvailablePortFinder.getNextAvailable(); @@ -57,7 +61,7 @@ public class ThriftConsumerAsyncTest extends CamelTestSupport { private int allTypesResult; private Work echoResult; - @Before + @BeforeEach public void startThriftClient() throws IOException, TTransportException { if (transport == null) { LOG.info("Connecting to the Thrift server on port: {}", THRIFT_TEST_PORT); @@ -66,7 +70,7 @@ public class ThriftConsumerAsyncTest extends CamelTestSupport { } } - @After + @AfterEach public void stopThriftClient() throws Exception { if (transport != null) { transport.close(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerConcurrentTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerConcurrentTest.java index 5de4e51..cf17850 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerConcurrentTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerConcurrentTest.java @@ -28,7 +28,7 @@ import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.TException; import org.apache.thrift.async.AsyncMethodCallback; import org.apache.thrift.async.TAsyncClientManager; @@ -40,10 +40,13 @@ import org.apache.thrift.transport.TNonblockingTransport; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; -import org.junit.Test; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; + public class ThriftConsumerConcurrentTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftConsumerConcurrentTest.class); @@ -83,7 +86,7 @@ public class ThriftConsumerConcurrentTest extends CamelTestSupport { LOG.info("Exception", e); } - assertNotNull("instanceId = " + instanceId, calculateResponse); + assertNotNull(calculateResponse, "instanceId = " + instanceId); assertEquals(instanceId * THRIFT_TEST_NUM1, calculateResponse); transport.close(); @@ -114,7 +117,7 @@ public class ThriftConsumerConcurrentTest extends CamelTestSupport { latch.await(5, TimeUnit.SECONDS); int calculateResponse = calculateCallback.getCalculateResponse(); - assertNotNull("instanceId = " + instanceId, calculateResponse); + assertNotNull(calculateResponse, "instanceId = " + instanceId); assertEquals(instanceId * THRIFT_TEST_NUM1, calculateResponse); transport.close(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSecurityTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSecurityTest.java index afa9179..6e7308c 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSecurityTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSecurityTest.java @@ -29,18 +29,22 @@ import org.apache.camel.support.jsse.KeyManagersParameters; import org.apache.camel.support.jsse.KeyStoreParameters; import org.apache.camel.support.jsse.SSLContextParameters; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TSSLTransportFactory; import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftConsumerSecurityTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftConsumerSecurityTest.class); private static final int THRIFT_TEST_PORT = AvailablePortFinder.getNextAvailable(); @@ -56,7 +60,7 @@ public class ThriftConsumerSecurityTest extends CamelTestSupport { private TProtocol protocol; private TTransport transport; - @Before + @BeforeEach public void startThriftSecureClient() throws IOException, TTransportException { if (transport == null) { LOG.info("Connecting to the secured Thrift server on port: {}", THRIFT_TEST_PORT); @@ -72,7 +76,7 @@ public class ThriftConsumerSecurityTest extends CamelTestSupport { } } - @After + @AfterEach public void stopThriftClient() throws Exception { if (transport != null) { transport.close(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSyncTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSyncTest.java index c68d47b..fb7bfcb 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSyncTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerSyncTest.java @@ -24,19 +24,23 @@ import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TFramedTransport; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftConsumerSyncTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftConsumerSyncTest.class); private static final int THRIFT_TEST_PORT = AvailablePortFinder.getNextAvailable(); @@ -47,7 +51,7 @@ public class ThriftConsumerSyncTest extends CamelTestSupport { private TProtocol protocol; private TTransport transport; - @Before + @BeforeEach public void startThriftClient() throws IOException, TTransportException { if (transport == null) { LOG.info("Connecting to the Thrift server on port: {}", THRIFT_TEST_PORT); @@ -58,7 +62,7 @@ public class ThriftConsumerSyncTest extends CamelTestSupport { } } - @After + @AfterEach public void stopThriftClient() throws Exception { if (transport != null) { transport.close(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerZlibCompressionTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerZlibCompressionTest.java index 12c3859..b2040c3 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerZlibCompressionTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerZlibCompressionTest.java @@ -24,19 +24,23 @@ import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; import org.apache.thrift.transport.TZlibTransport; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftConsumerZlibCompressionTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftConsumerZlibCompressionTest.class); private static final int THRIFT_TEST_PORT = AvailablePortFinder.getNextAvailable(); @@ -49,7 +53,7 @@ public class ThriftConsumerZlibCompressionTest extends CamelTestSupport { private TProtocol protocol; private TTransport transport; - @Before + @BeforeEach public void startThriftZlibClient() throws IOException, TTransportException { if (transport == null) { LOG.info("Connecting to the Thrift server with zlib compression on port: {}", THRIFT_TEST_PORT); @@ -62,7 +66,7 @@ public class ThriftConsumerZlibCompressionTest extends CamelTestSupport { } } - @After + @AfterEach public void stopThriftClient() throws Exception { if (transport != null) { transport.close(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerAsyncTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerAsyncTest.java index fd89b8a..118879e 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerAsyncTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerAsyncTest.java @@ -30,10 +30,15 @@ import org.apache.camel.component.thrift.generated.InvalidOperation; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.support.SynchronizationAdapter; -import org.junit.Test; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftProducerAsyncTest extends ThriftProducerBaseTest { private static final Logger LOG = LoggerFactory.getLogger(ThriftProducerAsyncTest.class); @@ -130,7 +135,7 @@ public class ThriftProducerAsyncTest extends ThriftProducerBaseTest { }); latch.await(5, TimeUnit.SECONDS); - assertTrue("Get an InvalidOperation exception", responseBody instanceof InvalidOperation); + assertTrue(responseBody instanceof InvalidOperation, "Get an InvalidOperation exception"); } diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerBaseTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerBaseTest.java index 14b9e5f..f65b948 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerBaseTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerBaseTest.java @@ -21,13 +21,13 @@ import java.io.IOException; import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.impl.CalculatorSyncServerImpl; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.server.THsHaServer; import org.apache.thrift.server.THsHaServer.Args; import org.apache.thrift.server.TServer; import org.apache.thrift.transport.TNonblockingServerSocket; -import org.junit.AfterClass; -import org.junit.BeforeClass; +import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.BeforeAll; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -42,7 +42,7 @@ public class ThriftProducerBaseTest extends CamelTestSupport { private static TNonblockingServerSocket serverTransport; private static TServer server; - @BeforeClass + @BeforeAll @SuppressWarnings({"unchecked", "rawtypes"}) public static void startThriftServer() throws Exception { processor = new Calculator.Processor(new CalculatorSyncServerImpl()); @@ -57,7 +57,7 @@ public class ThriftProducerBaseTest extends CamelTestSupport { new Thread(simple).start(); } - @AfterClass + @AfterAll public static void stopThriftServer() throws IOException { if (server != null) { server.stop(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSecurityTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSecurityTest.java index c9b4114..4eeac59 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSecurityTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSecurityTest.java @@ -37,17 +37,23 @@ import org.apache.camel.support.jsse.KeyStoreParameters; import org.apache.camel.support.jsse.SSLContextParameters; import org.apache.camel.support.jsse.TrustManagersParameters; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TThreadPoolServer; import org.apache.thrift.transport.TSSLTransportFactory; import org.apache.thrift.transport.TServerSocket; -import org.junit.AfterClass; -import org.junit.BeforeClass; -import org.junit.Test; +import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertNull; +import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.junit.jupiter.api.Assertions.fail; + public class ThriftProducerSecurityTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftProducerSecurityTest.class); @@ -65,7 +71,7 @@ public class ThriftProducerSecurityTest extends CamelTestSupport { private static final String SECURITY_STORE_PASSWORD = "camelinaction"; private static final int THRIFT_CLIENT_TIMEOUT = 2000; - @BeforeClass + @BeforeAll @SuppressWarnings({"unchecked", "rawtypes"}) public static void startThriftServer() throws Exception { processor = new Calculator.Processor(new CalculatorSyncServerImpl()); @@ -87,7 +93,7 @@ public class ThriftProducerSecurityTest extends CamelTestSupport { new Thread(simple).start(); } - @AfterClass + @AfterAll public static void stopThriftServer() throws IOException { if (server != null) { server.stop(); @@ -145,8 +151,8 @@ public class ThriftProducerSecurityTest extends CamelTestSupport { template.requestBody("direct:thrift-secured-calculate", requestBody); fail("Expect the exception here"); } catch (Exception ex) { - assertTrue("Expect CamelExecutionException", ex instanceof CamelExecutionException); - assertTrue("Get an InvalidOperation exception", ex.getCause() instanceof InvalidOperation); + assertTrue(ex instanceof CamelExecutionException, "Expect CamelExecutionException"); + assertTrue(ex.getCause() instanceof InvalidOperation, "Get an InvalidOperation exception"); } } diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSyncTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSyncTest.java index 96a4ac7..c48b497 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSyncTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerSyncTest.java @@ -27,10 +27,16 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.thrift.generated.InvalidOperation; import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; -import org.junit.Test; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertNull; +import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.junit.jupiter.api.Assertions.fail; + public class ThriftProducerSyncTest extends ThriftProducerBaseTest { private static final Logger LOG = LoggerFactory.getLogger(ThriftProducerSyncTest.class); @@ -82,8 +88,8 @@ public class ThriftProducerSyncTest extends ThriftProducerBaseTest { template.requestBody("direct:thrift-calculate", requestBody); fail("Expect the exception here"); } catch (Exception ex) { - assertTrue("Expect CamelExecutionException", ex instanceof CamelExecutionException); - assertTrue("Get an InvalidOperation exception", ex.getCause() instanceof InvalidOperation); + assertTrue(ex instanceof CamelExecutionException, "Expect CamelExecutionException"); + assertTrue(ex.getCause() instanceof InvalidOperation, "Get an InvalidOperation exception"); } } diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerZlibCompressionTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerZlibCompressionTest.java index 9afc74b..17d68cd 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerZlibCompressionTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftProducerZlibCompressionTest.java @@ -28,18 +28,23 @@ import org.apache.camel.component.thrift.generated.Operation; import org.apache.camel.component.thrift.generated.Work; import org.apache.camel.component.thrift.impl.CalculatorSyncServerImpl; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TThreadPoolServer; import org.apache.thrift.transport.TServerSocket; import org.apache.thrift.transport.TZlibTransport; -import org.junit.AfterClass; -import org.junit.BeforeClass; -import org.junit.Test; +import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertNull; +import static org.junit.jupiter.api.Assertions.assertTrue; + public class ThriftProducerZlibCompressionTest extends CamelTestSupport { private static final Logger LOG = LoggerFactory.getLogger(ThriftProducerZlibCompressionTest.class); @@ -53,7 +58,7 @@ public class ThriftProducerZlibCompressionTest extends CamelTestSupport { private static final int THRIFT_TEST_NUM2 = 13; private static final int THRIFT_CLIENT_TIMEOUT = 2000; - @BeforeClass + @BeforeAll @SuppressWarnings({"unchecked", "rawtypes"}) public static void startThriftServer() throws Exception { processor = new Calculator.Processor(new CalculatorSyncServerImpl()); @@ -74,7 +79,7 @@ public class ThriftProducerZlibCompressionTest extends CamelTestSupport { new Thread(simple).start(); } - @AfterClass + @AfterAll public static void stopThriftServer() throws IOException { if (server != null) { server.stop(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/local/ThriftThreadPoolServerTest.java b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/local/ThriftThreadPoolServerTest.java index 469a2de..3b17d2a 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/local/ThriftThreadPoolServerTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/component/thrift/local/ThriftThreadPoolServerTest.java @@ -24,7 +24,7 @@ import org.apache.camel.component.thrift.generated.Calculator; import org.apache.camel.component.thrift.impl.CalculatorSyncServerImpl; import org.apache.camel.component.thrift.server.ThriftThreadPoolServer; import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; +import org.apache.camel.test.junit5.CamelTestSupport; import org.apache.thrift.TException; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; @@ -32,12 +32,14 @@ import org.apache.thrift.server.TServer; import org.apache.thrift.transport.TSSLTransportFactory; import org.apache.thrift.transport.TServerSocket; import org.apache.thrift.transport.TTransport; -import org.junit.After; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import static org.junit.jupiter.api.Assertions.assertEquals; + /** * TBD */ @@ -60,7 +62,7 @@ public class ThriftThreadPoolServerTest extends CamelTestSupport { @SuppressWarnings({"rawtypes"}) private static Calculator.Processor processor; - @Before + @BeforeEach @SuppressWarnings({"unchecked", "rawtypes"}) public void startThriftServer() throws Exception { processor = new Calculator.Processor(new CalculatorSyncServerImpl()); @@ -81,7 +83,7 @@ public class ThriftThreadPoolServerTest extends CamelTestSupport { LOG.info("Thrift secured server started on port: {}", THRIFT_TEST_PORT); } - @After + @AfterEach public void stopThriftServer() throws IOException { if (server != null) { server.stop(); diff --git a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalJsonTest.java b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalJsonTest.java index 756ae21..025c899 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalJsonTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalJsonTest.java @@ -21,8 +21,10 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.dataformat.thrift.generated.Operation; import org.apache.camel.dataformat.thrift.generated.Work; -import org.apache.camel.test.junit4.CamelTestSupport; -import org.junit.Test; +import org.apache.camel.test.junit5.CamelTestSupport; +import org.junit.jupiter.api.Test; + +import static org.junit.jupiter.api.Assertions.assertEquals; public class ThriftMarshalAndUnmarshalJsonTest extends CamelTestSupport { diff --git a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalSpringTest.java b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalSpringTest.java index f34b935..1feb829 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalSpringTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalSpringTest.java @@ -22,10 +22,14 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.dataformat.thrift.generated.Operation; import org.apache.camel.dataformat.thrift.generated.Work; -import org.apache.camel.test.spring.CamelSpringTestSupport; -import org.junit.Test; +import org.apache.camel.test.spring.junit5.CamelSpringTestSupport; +import org.junit.jupiter.api.Test; import org.springframework.context.support.ClassPathXmlApplicationContext; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.junit.jupiter.api.Assertions.fail; + public class ThriftMarshalAndUnmarshalSpringTest extends CamelSpringTestSupport { private static final String WORK_TEST_COMMENT = "This is a test thrift data"; private static final int WORK_TEST_NUM1 = 1; @@ -63,7 +67,7 @@ public class ThriftMarshalAndUnmarshalSpringTest extends CamelSpringTestSupport }); fail("Expect the exception here"); } catch (Exception ex) { - assertTrue("Expect FailedToCreateRouteException", ex instanceof FailedToCreateRouteException); + assertTrue(ex instanceof FailedToCreateRouteException, "Expect FailedToCreateRouteException"); } } diff --git a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalTest.java b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalTest.java index f5da95c..fcee951 100644 --- a/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalTest.java +++ b/components/camel-thrift/src/test/java/org/apache/camel/dataformat/thrift/ThriftMarshalAndUnmarshalTest.java @@ -22,8 +22,12 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.dataformat.thrift.generated.Operation; import org.apache.camel.dataformat.thrift.generated.Work; -import org.apache.camel.test.junit4.CamelTestSupport; -import org.junit.Test; +import org.apache.camel.test.junit5.CamelTestSupport; +import org.junit.jupiter.api.Test; + +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.junit.jupiter.api.Assertions.fail; public class ThriftMarshalAndUnmarshalTest extends CamelTestSupport { private static final String WORK_TEST_COMMENT = "This is a test thrift data"; @@ -57,7 +61,7 @@ public class ThriftMarshalAndUnmarshalTest extends CamelTestSupport { }); fail("Expect the exception here"); } catch (Exception ex) { - assertTrue("Expect FailedToCreateRouteException", ex instanceof FailedToCreateRouteException); + assertTrue(ex instanceof FailedToCreateRouteException, "Expect FailedToCreateRouteException"); } }