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 b8db164..895b75f 100644
--- a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java
+++ b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java
@@ -109,6 +109,11 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
 				}
 				LOGGER.debug("connection closed: " + clientAddress);
 			}
+			catch (Exception e)
+			{
+				LOGGER.warn("Stream handling failed", e);
+				throw e;
+			}
 
 			return null;
 		}
@@ -181,7 +186,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
 	@Override
 	public void start() throws Exception {
 
-		final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(1);
+		final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(100);
 
 		serverThreadPool.submit(() -> {
 			Thread.currentThread().setName("db-ingestion");