Passing camel contextes.

vpro · Jun 15, 2024 · 51f3779 · 51f3779
1 parent 4e83657
commit 51f3779
Show file tree

Hide file tree

Showing 6 changed files with 16 additions and 17 deletions.
diff --git a/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherComponent.java b/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherComponent.java
@@ -28,7 +28,7 @@ public class FileWatcherComponent extends DefaultComponent {
 
     @Override
     protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
-        Endpoint endpoint = new FileWatcherEndpoint(uri, this);
+        Endpoint endpoint = new FileWatcherEndpoint(getCamelContext(), uri, this);
         setProperties(endpoint, parameters);
         return endpoint;
     }

diff --git a/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherEndpoint.java b/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherEndpoint.java
@@ -16,9 +16,7 @@
  */
 package nl.vpro.camel;
 
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
+import org.apache.camel.*;
 import org.apache.camel.support.DefaultEndpoint;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -31,8 +29,9 @@ class FileWatcherEndpoint extends DefaultEndpoint {
     private static final Logger LOG = LoggerFactory.getLogger(FileWatcherEndpoint.class);
 
 
-    FileWatcherEndpoint(String uri, FileWatcherComponent component) {
+    FileWatcherEndpoint(CamelContext camelContext, String uri, FileWatcherComponent component) {
         super(uri, component);
+        setCamelContext(camelContext);
     }
 
     @Override

diff --git a/camel-newrelic/src/main/java/nl/vpro/camel/newrelic/TraceComponent.java b/camel-newrelic/src/main/java/nl/vpro/camel/newrelic/TraceComponent.java
@@ -16,16 +16,16 @@
  */
 package nl.vpro.camel.newrelic;
 
+import java.util.Map;
+
 import org.apache.camel.Endpoint;
 import org.apache.camel.support.DefaultComponent;
 
-import java.util.Map;
-
 public class TraceComponent extends DefaultComponent {
 
     @Override
     protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
-        Endpoint endpoint = new TraceEndpoint(uri, this);
+        Endpoint endpoint = new TraceEndpoint(getCamelContext(), uri, this);
         setProperties(endpoint, parameters);
         return endpoint;
     }

diff --git a/camel-newrelic/src/main/java/nl/vpro/camel/newrelic/TraceEndpoint.java b/camel-newrelic/src/main/java/nl/vpro/camel/newrelic/TraceEndpoint.java
@@ -16,24 +16,23 @@
  */
 package nl.vpro.camel.newrelic;
 
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.support.DefaultConsumer;
-import org.apache.camel.support.DefaultEndpoint;
-
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
 
+import org.apache.camel.*;
+import org.apache.camel.support.DefaultConsumer;
+import org.apache.camel.support.DefaultEndpoint;
+
 /**
  * @author Roelof Jan Koekoek
  * @since 1.1
  */
 class TraceEndpoint extends DefaultEndpoint {
     private final CopyOnWriteArrayList<DefaultConsumer> consumers = new CopyOnWriteArrayList<>();
 
-    TraceEndpoint(String uri, TraceComponent component) {
+    TraceEndpoint(CamelContext context, String uri, TraceComponent component) {
         super(uri, component);
+        setCamelContext(context);
     }
 
     @Override

diff --git a/camel-scp/src/main/java/nl/vpro/camel/ScpComponent.java b/camel-scp/src/main/java/nl/vpro/camel/ScpComponent.java
@@ -11,7 +11,7 @@ public class ScpComponent extends DefaultComponent {
 
     @Override
     protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
-        Endpoint endpoint = new ScpEndpoint(uri, remaining, this);
+        Endpoint endpoint = new ScpEndpoint(getCamelContext(), uri, remaining, this);
         setProperties(endpoint, parameters);
         return endpoint;
     }

diff --git a/camel-scp/src/main/java/nl/vpro/camel/ScpEndpoint.java b/camel-scp/src/main/java/nl/vpro/camel/ScpEndpoint.java
@@ -108,9 +108,10 @@ public class ScpEndpoint extends DefaultEndpoint {
     private String userHosts;
 
 
-    public ScpEndpoint(String uri, String remaining, ScpComponent component) {
+    public ScpEndpoint(CamelContext context, String uri, String remaining, ScpComponent component) {
         super(uri, component);
         this.remoteHostName = remaining;
+        setCamelContext(context);
     }