diff --git a/proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/PacketEncoder.java b/proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/PacketEncoder.java index 7e92a18..324b9f7 100644 --- a/proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/PacketEncoder.java +++ b/proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/PacketEncoder.java @@ -13,8 +13,10 @@ import mc.core.network.SCPacket; import mc.core.network.proto_1_12_2.ByteArrayOutputNetStream; import mc.core.network.proto_1_12_2.State; import mc.core.network.proto_1_12_2.netty.wrappers.WrapperNetOutputStream; +import org.slf4j.helpers.MessageFormatter; import static mc.core.network.proto_1_12_2.netty.NettyServer.ATTR_STATE; +import static org.slf4j.helpers.MessageFormatter.format; @Slf4j public class PacketEncoder extends MessageToByteEncoder { @@ -41,13 +43,17 @@ public class PacketEncoder extends MessageToByteEncoder { log.debug("Send {}:{}", state, packet); - NetOutputStream netStream = new ByteArrayOutputNetStream(); - packet.writeSelf(netStream); - byte[] bytes = ((ByteArrayOutputNetStream) netStream).toByteArray(); - netStream = new WrapperNetOutputStream(out); + try { + NetOutputStream netStream = new ByteArrayOutputNetStream(); + packet.writeSelf(netStream); + byte[] bytes = ((ByteArrayOutputNetStream) netStream).toByteArray(); + netStream = new WrapperNetOutputStream(out); - netStream.writeVarInt(bytes.length + sizeVarInt(id)); - netStream.writeVarInt(id); - netStream.writeBytes(bytes); + netStream.writeVarInt(bytes.length + sizeVarInt(id)); + netStream.writeVarInt(id); + netStream.writeBytes(bytes); + } catch (Throwable t) { + log.error(format("Error encoding packet {}:{}", state, packet).getMessage(), t); + } } }