improved security handling and added shutdown handler

git-svn-id: https://joinup.ec.europa.eu/svn/mocca/trunk@27 8a26b1a7-26f0-462f-b9ef-d0e30c41f5a4

1 files changed, 9 insertions, 2 deletions

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) {