diff --git a/bridge-protocol/build.gradle b/bridge-protocol/build.gradle index 6b537fc..1518b24 100644 --- a/bridge-protocol/build.gradle +++ b/bridge-protocol/build.gradle @@ -1,5 +1,5 @@ group = 'asys' -version = '0.3-SNAPSHOT' +version = '0.3.1-SNAPSHOT' task jar(type: Jar, overwrite: true) { // не собирать jar diff --git a/bridge-protocol/src/main/java/asys/mcsmanager/packets/codec/PacketDecoder.java b/bridge-protocol/src/main/java/asys/mcsmanager/packets/codec/PacketDecoder.java index ea926a8..cdcd832 100644 --- a/bridge-protocol/src/main/java/asys/mcsmanager/packets/codec/PacketDecoder.java +++ b/bridge-protocol/src/main/java/asys/mcsmanager/packets/codec/PacketDecoder.java @@ -19,12 +19,15 @@ public class PacketDecoder extends ReplayingDecoder { protected void decode(ChannelHandlerContext contect, ByteBuf inBuf, List out) throws Exception { int id = inBuf.readUnsignedByte(); Class pktClass = contect.channel().attr(KNOWN_PACKETS).get().get(id); - if (pktClass == null) return; + if (pktClass == null) return; //TODO надо бы в логгере писать про отсутствующий пакет if (contect.channel().attr(KNOWN_HANDLERS).get().containsKey(pktClass)) { Packet packet = pktClass.newInstance(); packet.readSelfData(inBuf); out.add(packet); + } else { + //TODO по хорошему, надо информровать, что отсутствует обработчик пакета + inBuf.skipBytes(inBuf.readableBytes()); } } }