dashboard #1
@@ -90,7 +90,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
|
||||
port = serverSocket.getLocalPort();
|
||||
LOGGER.info("listening on port " + serverSocket.getLocalPort());
|
||||
|
||||
serverSocket.setSoTimeout((int) TimeUnit.MILLISECONDS.toMillis(2));
|
||||
serverSocket.setSoTimeout((int) TimeUnit.MILLISECONDS.toMillis(100));
|
||||
started.countDown(); // notify caller that the socket is now listening
|
||||
|
||||
while (acceptNewConnections.get()) {
|
||||
|
||||
Reference in New Issue
Block a user