From 74033addbe22fb0059cb7dc68bf812c7a35be45a Mon Sep 17 00:00:00 2001 From: Andrew Steinborn Date: Sat, 28 Oct 2023 19:53:29 -0400 Subject: [PATCH] Fix bug in `VelocityRegisteredServer#ping()` --- .../proxy/server/VelocityRegisteredServer.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/proxy/src/main/java/com/velocitypowered/proxy/server/VelocityRegisteredServer.java b/proxy/src/main/java/com/velocitypowered/proxy/server/VelocityRegisteredServer.java index 928b4ee72..ca609460f 100644 --- a/proxy/src/main/java/com/velocitypowered/proxy/server/VelocityRegisteredServer.java +++ b/proxy/src/main/java/com/velocitypowered/proxy/server/VelocityRegisteredServer.java @@ -124,9 +124,10 @@ public class VelocityRegisteredServer implements RegisteredServer, ForwardingAud }).connect(serverInfo.getAddress()).addListener((ChannelFutureListener) future -> { if (future.isSuccess()) { MinecraftConnection conn = future.channel().pipeline().get(MinecraftConnection.class); - conn.setActiveSessionHandler(StateRegistry.HANDSHAKE, - new PingSessionHandler(pingFuture, VelocityRegisteredServer.this, conn, - pingOptions.getProtocolVersion())); + PingSessionHandler handler = new PingSessionHandler(pingFuture, + VelocityRegisteredServer.this, conn, pingOptions.getProtocolVersion()); + conn.setActiveSessionHandler(StateRegistry.HANDSHAKE, handler); + conn.addSessionHandler(StateRegistry.LOGIN, handler); } else { pingFuture.completeExceptionally(future.cause()); }