You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gn...@apache.org on 2026/03/20 10:11:31 UTC
(camel) 07/07: CAMEL-23214: Fix AvroConsumerTestSupport compilation - migrate setupFreePort to @RegisterExtension
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 <gn...@gmail.com>
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 <no...@anthropic.com>
---
.../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