This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 5400ca14d2e5 chore(components): clear jetty compilation warnings
5400ca14d2e5 is described below
commit 5400ca14d2e5c4ba0fd987666c0cd2ddeba03fa9
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();
