[camel] branch main updated: camel-websocket: safe extension of endpoint (#5824)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus 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 bad9a06  camel-websocket: safe extension of endpoint (#5824)
bad9a06 is described below

commit bad9a0695a77c3882e58be628230890b8842fc1d
Author: Paul Galbraith <pa...@gmail.com>
AuthorDate: Sat Jul 24 02:02:36 2021 -0400

    camel-websocket: safe extension of endpoint (#5824)
    
    * camel-websocket: move endpoint init code into endpoint constructor
    
    * Revert "camel-websocket: move endpoint init code into endpoint constructor"
    
    This reverts commit e702a359
    
    * Alternative for safe extension of camel-websocket endpoint
---
 .../org/apache/camel/component/websocket/WebsocketComponent.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 055a6f4..696ca67 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 = new WebsocketEndpoint(this, uri, remaining, parameters);
+        WebsocketEndpoint endpoint = newEndpoint(uri, remaining, parameters);
 
         if (enableJmx != null) {
             endpoint.setEnableJmx(enableJmx);
@@ -328,6 +328,10 @@ 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 void setWebSocketComponentServletInitialParameter(ServletContextHandler context, WebsocketEndpoint endpoint) {
         if (endpoint.getBufferSize() != null) {
             context.setInitParameter("bufferSize", endpoint.getBufferSize().toString());