diff --git a/src/java/com/threerings/presents/server/net/ConnectionManager.java b/src/java/com/threerings/presents/server/net/ConnectionManager.java index 922d80fb5..3a8d18da6 100644 --- a/src/java/com/threerings/presents/server/net/ConnectionManager.java +++ b/src/java/com/threerings/presents/server/net/ConnectionManager.java @@ -404,6 +404,12 @@ public class ConnectionManager extends LoopingThread // connection with the new one _handlers.put(selkey, rconn); + // transfer any overflow queue for that connection + Object oflowHandler = _oflowqs.remove(conn); + if (oflowHandler != null) { + _oflowqs.put(rconn, oflowHandler); + } + // and let our observers know about our new connection notifyObservers(CONNECTION_ESTABLISHED, rconn, conn.getAuthRequest(), conn.getAuthResponse());