Skip to content

Commit 81e8e15

Browse files
committed
Fix Jetty issue with "Blocking message pending 10000"
1 parent ca73207 commit 81e8e15

File tree

1 file changed

+6
-3
lines changed
  • games-server/src/main/kotlin/net/zomis/games/server2/ws

1 file changed

+6
-3
lines changed

games-server/src/main/kotlin/net/zomis/games/server2/ws/WebClient.kt

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,14 @@ import net.zomis.games.server2.Client
77
internal class WebClient(val conn: WsSession): Client() {
88

99
private val logger = KLoggers.logger(this)
10+
private val lock = Any()
1011

1112
override fun sendData(data: String) {
12-
if (conn.isOpen) {
13-
logger.info("Send to $this: $data")
14-
conn.send(data)
13+
synchronized(lock) {
14+
if (conn.isOpen) {
15+
logger.info("Send to $this: $data")
16+
conn.send(data)
17+
}
1518
}
1619
}
1720

0 commit comments

Comments
 (0)