This is an automated email from the ASF dual-hosted git repository. gnodet pushed a commit to branch CAMEL-23214-port-misc in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5781c8553b60fd167721880d0bb7a13e3f974ce3 Author: Guillaume Nodet <[email protected]> AuthorDate: Fri Mar 20 08:01:44 2026 +0100 CAMEL-23214: Fix AvroConsumerTestSupport compilation - migrate setupFreePort to @RegisterExtension Co-Authored-By: Claude Opus 4.6 <[email protected]> --- .../camel/component/avro/AvroConsumerTestSupport.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/components/camel-avro-rpc/camel-avro-rpc-component/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java b/components/camel-avro-rpc/camel-avro-rpc-component/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java index 9ea12f3845f2..1c8d8527f611 100644 --- a/components/camel-avro-rpc/camel-avro-rpc-component/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java +++ b/components/camel-avro-rpc/camel-avro-rpc-component/src/test/java/org/apache/camel/component/avro/AvroConsumerTestSupport.java @@ -27,6 +27,7 @@ import org.apache.camel.avro.impl.KeyValueProtocolImpl; import org.apache.camel.avro.test.TestPojo; import org.apache.camel.avro.test.TestReflection; import org.apache.camel.avro.test.TestReflectionImpl; +import org.apache.camel.test.AvailablePortFinder; import org.apache.camel.test.junit6.TestNameExtension; import org.junit.jupiter.api.Order; import org.junit.jupiter.api.Test; @@ -40,8 +41,13 @@ public abstract class AvroConsumerTestSupport extends AvroTestSupport { public static final String REFLECTION_TEST_NAME = "Chucky"; public static final int REFLECTION_TEST_AGE = 100; - protected int avroPortMessageInRoute = setupFreePort("avroPortMessageInRoute"); - protected int avroPortForWrongMessages = setupFreePort("avroPortForWrongMessages"); + @RegisterExtension + AvailablePortFinder.Port avroPortMessageInRouteHolder = AvailablePortFinder.find(); + @RegisterExtension + AvailablePortFinder.Port avroPortForWrongMessagesHolder = AvailablePortFinder.find(); + + protected int avroPortMessageInRoute; + protected int avroPortForWrongMessages; Transceiver transceiver; Requestor requestor; @@ -62,6 +68,15 @@ public abstract class AvroConsumerTestSupport extends AvroTestSupport { @Order(10) TestNameExtension testNameExtension = new TestNameExtension(); + @Override + protected void doPreSetup() throws Exception { + super.doPreSetup(); + avroPortMessageInRoute = avroPortMessageInRouteHolder.getPort(); + avroPortForWrongMessages = avroPortForWrongMessagesHolder.getPort(); + System.setProperty("avroPortMessageInRoute", String.valueOf(avroPortMessageInRoute)); + System.setProperty("avroPortForWrongMessages", String.valueOf(avroPortForWrongMessages)); + } + protected abstract void initializeTranceiver() throws IOException; @Override
