diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/BlockingWriteCallback.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/BlockingWriteCallback.java index 2763eb56c5e2..f2828cc09639 100644 --- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/BlockingWriteCallback.java +++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/BlockingWriteCallback.java @@ -37,7 +37,14 @@ public WriteBlocker acquireWriteBlocker() throws IOException { return new WriteBlocker(acquire()); } - + + @Override + protected long getIdleTimeout() + { + // Timeout if sending message takes more than 30 sec + return 30000; + } + public static class WriteBlocker implements WriteCallback, Callback.NonBlocking, AutoCloseable { private final Blocker blocker;