Repository: camel
Updated Branches:
  refs/heads/master 2a1288e0a -> 6522c9b21


CAMEL-11274- add extensibility to ReloadStrategySupport


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6522c9b2
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6522c9b2
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6522c9b2

Branch: refs/heads/master
Commit: 6522c9b21ac67a9a73fcfbe522a6a8365663402c
Parents: 2a1288e
Author: onders86 <ondersez...@gmail.com>
Authored: Tue May 23 22:37:10 2017 +0300
Committer: Claus Ibsen <davscl...@apache.org>
Committed: Wed May 24 09:38:03 2017 +0200

----------------------------------------------------------------------
 .../apache/camel/support/ReloadStrategySupport.java  | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/6522c9b2/camel-core/src/main/java/org/apache/camel/support/ReloadStrategySupport.java
----------------------------------------------------------------------
diff --git 
a/camel-core/src/main/java/org/apache/camel/support/ReloadStrategySupport.java 
b/camel-core/src/main/java/org/apache/camel/support/ReloadStrategySupport.java
index d99bc62..44971f4 100644
--- 
a/camel-core/src/main/java/org/apache/camel/support/ReloadStrategySupport.java
+++ 
b/camel-core/src/main/java/org/apache/camel/support/ReloadStrategySupport.java
@@ -46,10 +46,11 @@ import org.slf4j.LoggerFactory;
  */
 public abstract class ReloadStrategySupport extends ServiceSupport implements 
ReloadStrategy {
     protected final Logger log = LoggerFactory.getLogger(getClass());
-    private CamelContext camelContext;
 
     // store state
-    private final Map<String, ResourceState> cache = new LRUCache<String, 
ResourceState>(100);
+    protected final Map<String, Object> cache = new LRUCache<String, 
Object>(100);
+
+    private CamelContext camelContext;
 
     private int succeeded;
     private int failed;
@@ -80,7 +81,7 @@ public abstract class ReloadStrategySupport extends 
ServiceSupport implements Re
             return;
         }
 
-        ResourceState state = cache.get(name);
+        ResourceState state = ObjectHelper.cast(ResourceState.class, 
cache.get(name));
         if (state == null) {
             state = new ResourceState(name, dom, xml);
             cache.put(name, state);
@@ -181,6 +182,14 @@ public abstract class ReloadStrategySupport extends 
ServiceSupport implements Re
     public int getFailedCounter() {
         return failed;
     }
+    
+    public void setSucceeded(int succeeded) {
+        this.succeeded = succeeded;
+    }
+    
+    public void setFailed(int failed) {
+        this.failed = failed;
+    }
 
     @ManagedOperation(description = "Reset counters")
     public void resetCounters() {

Reply via email to