diff --git a/src/main/java/org/arl/fjage/connectors/WebSocketConnector.java b/src/main/java/org/arl/fjage/connectors/WebSocketConnector.java index 726a9645..3572e1d8 100644 --- a/src/main/java/org/arl/fjage/connectors/WebSocketConnector.java +++ b/src/main/java/org/arl/fjage/connectors/WebSocketConnector.java @@ -250,7 +250,7 @@ void write(String s) { if (session != null && session.isOpen()) { Future f = session.getRemote().sendStringByFuture(s); try { - f.get(500, TimeUnit.MILLISECONDS); + f.get(2, TimeUnit.SECONDS); } catch (TimeoutException e){ log.fine("Sending timed out. Closing connection to " + session.getRemoteAddress()); session.disconnect();