This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6f088a755e9d173ff7e63a14f1029b88e4eef6d8 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Jun 20 11:10:12 2022 +0200 (chores) camel-websocket: removed/documented unused parameters --- .../org/apache/camel/component/websocket/WebsocketComponent.java | 6 +++--- .../org/apache/camel/component/websocket/WebsocketEndpoint.java | 3 +-- .../org/apache/camel/component/websocket/WebsocketProducer.java | 6 +++++- .../org/apache/camel/component/websocket/WebsocketEndpointTest.java | 2 +- 4 files changed, 10 insertions(+), 7 deletions(-) diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java index 696ca674bb8..98fc9f9052f 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java @@ -292,7 +292,7 @@ public class WebsocketComponent extends DefaultComponent implements SSLContextPa int port = extractPortNumber(remaining); String host = extractHostName(remaining); - WebsocketEndpoint endpoint = newEndpoint(uri, remaining, parameters); + WebsocketEndpoint endpoint = newEndpoint(uri, remaining); if (enableJmx != null) { endpoint.setEnableJmx(enableJmx); @@ -328,8 +328,8 @@ public class WebsocketComponent extends DefaultComponent implements SSLContextPa return endpoint; } - protected WebsocketEndpoint newEndpoint(String uri, String remaining, Map<String, Object> parameters) { - return new WebsocketEndpoint(this, uri, remaining, parameters); + protected WebsocketEndpoint newEndpoint(String uri, String remaining) { + return new WebsocketEndpoint(this, uri, remaining); } protected void setWebSocketComponentServletInitialParameter(ServletContextHandler context, WebsocketEndpoint endpoint) { diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java index 16c2e13ebd9..4cdf5b3399f 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java @@ -19,7 +19,6 @@ package org.apache.camel.component.websocket; import java.net.URI; import java.net.URISyntaxException; import java.util.List; -import java.util.Map; import org.apache.camel.Category; import org.apache.camel.Consumer; @@ -85,7 +84,7 @@ public class WebsocketEndpoint extends DefaultEndpoint { @UriParam(label = "consumer", defaultValue = "any") private String subprotocol; - public WebsocketEndpoint(WebsocketComponent component, String uri, String resourceUri, Map<String, Object> parameters) { + public WebsocketEndpoint(WebsocketComponent component, String uri, String resourceUri) { super(uri, component); this.resourceUri = resourceUri; this.component = component; diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java index 63bc0b5f079..06eb2d297e9 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java @@ -181,8 +181,12 @@ public class WebsocketProducer extends DefaultProducer implements WebsocketProdu /** * Called when a sleep is interrupted; allows derived classes to handle this case differently + * + * @param e the interrupted exception instance + * @param exchange the exchange being processed */ - protected void handleSleepInterruptedException(InterruptedException e, Exchange exchange) throws InterruptedException { + protected void handleSleepInterruptedException(InterruptedException e, @SuppressWarnings("unused") Exchange exchange) + throws InterruptedException { if (LOG.isDebugEnabled()) { LOG.debug("Sleep interrupted, are we stopping? {}", isStopping() || isStopped()); } diff --git a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointTest.java b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointTest.java index c2b6c5ddb97..0eb8f7a5a15 100644 --- a/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointTest.java +++ b/components/camel-websocket/src/test/java/org/apache/camel/component/websocket/WebsocketEndpointTest.java @@ -50,7 +50,7 @@ public class WebsocketEndpointTest { @BeforeEach public void setUp() throws Exception { - websocketEndpoint = new WebsocketEndpoint(component, URI, REMAINING, null); + websocketEndpoint = new WebsocketEndpoint(component, URI, REMAINING); component = new WebsocketComponent(); component.setPort(1988); component.setHost("localhost");
