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 082e2c1..e14d99a 100644 --- a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java +++ b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java @@ -121,7 +121,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean { @Override public void start() throws Exception { - final ArrayBlockingQueue queue = new ArrayBlockingQueue<>(100); + final ArrayBlockingQueue queue = new ArrayBlockingQueue<>(10_000); serverThreadPool.submit(() -> { Thread.currentThread().setName("db-ingestion");