diff options
Diffstat (limited to 'bkucommon/src')
-rw-r--r-- | bkucommon/src/main/java/at/gv/egiz/bku/binding/BindingProcessorManagerImpl.java | 5 |
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); |