X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.document.server%2Fsrc%2Forg%2Fsimantics%2Fdocument%2Fserver%2FDocumentHistoryListener.java;h=2fcb17c5c6a3cc877fbe024f6be166da172e8bda;hb=4f87cc11bc1e4a56860f278798e41834ea1fbb3f;hp=ca4adef25a280ff77bfcbbd4d1ff92184151d194;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.document.server/src/org/simantics/document/server/DocumentHistoryListener.java b/bundles/org.simantics.document.server/src/org/simantics/document/server/DocumentHistoryListener.java index ca4adef25..2fcb17c5c 100644 --- a/bundles/org.simantics.document.server/src/org/simantics/document/server/DocumentHistoryListener.java +++ b/bundles/org.simantics.document.server/src/org/simantics/document/server/DocumentHistoryListener.java @@ -1,51 +1,53 @@ -package org.simantics.document.server; - -import java.util.List; - -import org.simantics.Logger; -import org.simantics.db.procedure.Listener; - -public class DocumentHistoryListener implements Listener> { - - final private DocumentHistory history; - - private boolean disposed = false; - - DocumentHistoryListener(DocumentHistory history) { - this.history = history; - } - - @Override - public void execute(List result) { - - synchronized(history) { - - history.refresh(result); - if(!history.hasListeners()) { - history.removeUpdater(); - disposed = true; - } - - } - - } - - @Override - public void exception(Throwable t) { - Logger.defaultLogError(t); - } - - @Override - public boolean isDisposed() { - if(!disposed) { - synchronized(history) { - if(!history.hasListeners()) { - history.removeUpdater(); - disposed = true; - } - } - } - return disposed; - } - -} +package org.simantics.document.server; + +import java.util.List; + +import org.simantics.db.procedure.Listener; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class DocumentHistoryListener implements Listener> { + private static final Logger LOGGER = LoggerFactory.getLogger(DocumentHistoryListener.class); + + final private DocumentHistory history; + + private boolean disposed = false; + + DocumentHistoryListener(DocumentHistory history) { + this.history = history; + } + + @Override + public void execute(List result) { + + synchronized(history) { + + history.refresh(result); + if(!history.hasListeners()) { + history.removeUpdater(); + disposed = true; + } + + } + + } + + @Override + public void exception(Throwable t) { + LOGGER.warn("DocumentHistoryListener received an exception.", t); + } + + @Override + public boolean isDisposed() { + if(!disposed) { + synchronized(history) { + if(!history.hasListeners()) { + history.removeUpdater(); + disposed = true; + } + } + } + return disposed; + } + +}