This is an automated email from the ASF dual-hosted git repository. fmariani pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 744121cca555638eebc0923756e30d34c7dcffdb Author: Pasquale Congiusti <[email protected]> AuthorDate: Fri Jan 16 10:28:09 2026 +0100 chore(components): clear jetty compilation warnings Ref CAMEL-22549 --- .../jetty12/CamelInputStreamContentSource.java | 2 +- .../apache/camel/component/jetty/HandlerTest.java | 36 +++++++++++----------- .../jetty/HttpProducerJMXBeansIssueManualIT.java | 2 +- .../camel/component/jetty/HttpRouteTest.java | 3 +- 4 files changed, 22 insertions(+), 21 deletions(-) diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty12/CamelInputStreamContentSource.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty12/CamelInputStreamContentSource.java index 40f5927a4f52..42ec25fb6310 100644 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty12/CamelInputStreamContentSource.java +++ b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty12/CamelInputStreamContentSource.java @@ -25,7 +25,7 @@ public class CamelInputStreamContentSource extends InputStreamContentSource { private final int length; public CamelInputStreamContentSource(InputStream stream, int length) { - super(stream); + super(stream, null); this.length = length; } diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java index d5bed44aa7f1..33ccd9208319 100644 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java +++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java @@ -43,41 +43,41 @@ public class HandlerTest extends BaseJettyTest { @Test public void testWithOneHandler() throws Exception { // First test the situation where one should invoke the handler once - assertEquals(0, statisticsHandler1.getRequests()); - assertEquals(0, statisticsHandler2.getRequests()); - assertEquals(0, statisticsHandler3.getRequests()); + assertEquals(0, statisticsHandler1.getRequestTotal()); + assertEquals(0, statisticsHandler2.getRequestTotal()); + assertEquals(0, statisticsHandler3.getRequestTotal()); InputStream html = (InputStream) template.requestBody("http://localhost:"; + port1, ""); BufferedReader br = IOHelper.buffered(new InputStreamReader(html)); assertEquals(htmlResponse, br.readLine()); - assertEquals(1, statisticsHandler1.getRequests()); - assertEquals(0, statisticsHandler2.getRequests()); - assertEquals(0, statisticsHandler3.getRequests()); + assertEquals(1, statisticsHandler1.getRequestTotal()); + assertEquals(0, statisticsHandler2.getRequestTotal()); + assertEquals(0, statisticsHandler3.getRequestTotal()); } @Test public void testWithTwoHandlers() throws Exception { // First test the situation where one should invoke the handler once - assertEquals(0, statisticsHandler1.getRequests()); - assertEquals(0, statisticsHandler2.getRequests()); - assertEquals(0, statisticsHandler3.getRequests()); + assertEquals(0, statisticsHandler1.getRequestTotal()); + assertEquals(0, statisticsHandler2.getRequestTotal()); + assertEquals(0, statisticsHandler3.getRequestTotal()); InputStream html = (InputStream) template.requestBody("http://localhost:"; + port2, ""); BufferedReader br = IOHelper.buffered(new InputStreamReader(html)); assertEquals(htmlResponse, br.readLine()); - assertEquals(0, statisticsHandler1.getRequests()); - assertEquals(1, statisticsHandler2.getRequests()); - assertEquals(1, statisticsHandler3.getRequests()); + assertEquals(0, statisticsHandler1.getRequestTotal()); + assertEquals(1, statisticsHandler2.getRequestTotal()); + assertEquals(1, statisticsHandler3.getRequestTotal()); } @Test public void testWithTwoHandlersTwoEndpointsOnSamePort() throws Exception { // First test the situation where one should invoke the handler once - assertEquals(0, statisticsHandler1.getRequests()); - assertEquals(0, statisticsHandler2.getRequests()); - assertEquals(0, statisticsHandler3.getRequests()); + assertEquals(0, statisticsHandler1.getRequestTotal()); + assertEquals(0, statisticsHandler2.getRequestTotal()); + assertEquals(0, statisticsHandler3.getRequestTotal()); InputStream html1 = (InputStream) template.requestBody("http://localhost:"; + port2, ""); BufferedReader br1 = IOHelper.buffered(new InputStreamReader(html1)); @@ -87,9 +87,9 @@ public class HandlerTest extends BaseJettyTest { BufferedReader br2 = IOHelper.buffered(new InputStreamReader(html2)); assertEquals(htmlResponse, br2.readLine()); - assertEquals(0, statisticsHandler1.getRequests()); - assertEquals(2, statisticsHandler2.getRequests()); - assertEquals(2, statisticsHandler3.getRequests()); + assertEquals(0, statisticsHandler1.getRequestTotal()); + assertEquals(2, statisticsHandler2.getRequestTotal()); + assertEquals(2, statisticsHandler3.getRequestTotal()); } @Override diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueManualIT.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueManualIT.java index 9c11990d2c5b..d64880dabcc7 100644 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueManualIT.java +++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueManualIT.java @@ -36,7 +36,7 @@ public final class HttpProducerJMXBeansIssueManualIT extends BaseJettyTest { @BeforeEach public void doPreSetup() throws Exception { // to enable the JMX connector - enableJMX(); + this.testConfigurationBuilder.withEnableJMX(); System.setProperty("org.apache.camel.jmx.createRmiConnector", "True"); } diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java index 19555475f7ae..8c34c7bc2d82 100644 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java +++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java @@ -252,7 +252,8 @@ public class HttpRouteTest extends BaseJettyTest { } }); - from("jetty:http://localhost:"; + port3 + "/noStreamCache?disableStreamCache=true").noStreamCaching() + from("jetty:http://localhost:"; + port3 + "/noStreamCache?disableStreamCache=true") + .streamCache(false) .process(new Processor() { public void process(Exchange exchange) { InputStream is = (InputStream) exchange.getIn().getBody();
