2 files changed, 12 insertions, 3 deletions
diff --git a/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManager.java b/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManager.java
index ed37f08f..aaf81e51 100644
--- a/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManager.java
+++ b/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManager.java
@@ -99,5 +99,7 @@ public interface BindingProcessorManager {
    */
   public Set<Id> getManagedIds();
       
-  public void shutdown();
+  public void shutdown();
+  
+  public void shutdownNow();
 }
 \ No newline at end of file
diff --git a/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java b/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java
index 6f5ca2d2..0082de26 100644
--- a/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java
+++ b/bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java
@@ -149,6 +149,11 @@ public class BindingProcessorManagerImpl implements BindingProcessorManager {
   public void shutdown() {
     log.info("Shutting down the BindingProcessorManager");
     executorService.shutdown();
+  }
+  
+  public void shutdownNow() {
+  	log.info("Shutting down the BindingProcessorManager NOW!");
+    executorService.shutdownNow();
   }
 
   /**
@@ -223,7 +228,8 @@ public class BindingProcessorManagerImpl implements BindingProcessorManager {
       throw new SLRuntimeException(
           "Clashing ids, cannot process bindingprocessor with id:"
               + aBindingProcessor.getId());
-    }
+    }
+    log.debug("processing bindingprocessor: "+aBindingProcessor.getId());
     Future<?> f = executorService.submit(aBindingProcessor);
     bindingProcessorMap.put(aBindingProcessor.getId(), new MapEntityWrapper(f,
         aBindingProcessor));
@@ -235,7 +241,8 @@ public class BindingProcessorManagerImpl implements BindingProcessorManager {
   }
 
   @Override
-  public void removeBindingProcessor(Id sessionId) {
+  public void removeBindingProcessor(Id sessionId) {
+  	log.debug("Removing binding processor: "+sessionId);
     MapEntityWrapper wrapper = bindingProcessorMap
         .get(sessionId);
     if (wrapper == null) {