summaryrefslogtreecommitdiff
path: root/bkucommon
diff options
context:
space:
mode:
Diffstat (limited to 'bkucommon')
-rw-r--r--bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java5
1 files changed, 4 insertions, 1 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 cc1b7532..9757f7cc 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
@@ -285,16 +285,19 @@ public class BindingProcessorManagerImpl implements BindingProcessorManager {
log.debug("Removing binding processor: " + sessionId);
ProcessingContext ctx = contextMap.get(sessionId);
if (ctx == null) {
+ log.warn("no processing context to remove for session " + sessionId);
return;
}
Future f = ctx.getFuture();
-
+
// MapEntityWrapper wrapper = bindingProcessorMap.get(sessionId);
// if (wrapper == null) {
// return;
// }
// Future<?> f = wrapper.getFuture();
+
if (!f.isDone()) {
+ log.trace("canceling " + sessionId);
f.cancel(true);
}
contextMap.remove(sessionId);