diff --git a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java index 0a05dcd..467243f 100644 --- a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java +++ b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java @@ -124,6 +124,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean { final Entry entry = new Entry(date, duration, tags); return Optional.of(entry); } catch (final Exception e) { + LOGGER.error("Failed to create entry.", e); return Optional.empty(); } } diff --git a/performanceDb/src/main/java/org/lucares/performance/db/PdbFileIterator.java b/performanceDb/src/main/java/org/lucares/performance/db/PdbFileIterator.java index 182e556..8974df5 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/PdbFileIterator.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/PdbFileIterator.java @@ -8,9 +8,13 @@ import java.util.Queue; import java.util.function.Supplier; import org.lucares.pdb.api.Entry; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class PdbFileIterator implements Iterator, AutoCloseable { + private final static Logger LOGGER = LoggerFactory.getLogger(PdbFileIterator.class); + private static final class EntrySupplier implements Supplier, AutoCloseable { private final Queue pdbFiles; @@ -65,7 +69,7 @@ public class PdbFileIterator implements Iterator, AutoCloseable { try { pdbFiles.poll().close(); } catch (final Exception e) { - e.printStackTrace(); + LOGGER.warn("Closing pdb file failed.", e); } } } diff --git a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java index 56e1165..2b74d36 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java @@ -103,7 +103,7 @@ public class PerformanceDb implements AutoCloseable { } catch (final InvalidValueException | SyntaxException e) { LOGGER.info("skipping entry: " + e.getMessage() + " : " + entry); - LOGGER.debug("", e); + LOGGER.info("", e); } }