diff --git a/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java b/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java index 44ced03b..0a51184f 100644 --- a/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java +++ b/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java @@ -271,6 +271,11 @@ public class ChannelInjector extends ByteToMessageDecoder implements Injector { super.write(ctx, packet, promise); ChannelInjector.this.finalWrite(); } + + @Override + public boolean acceptOutboundMessage(Object msg) { + return msg instanceof WirePacket || MinecraftReflection.getPacketClass().isAssignableFrom(msg.getClass()); + } }; // Intercept recieved packets @@ -895,6 +900,8 @@ public class ChannelInjector extends ByteToMessageDecoder implements Injector { } } + + /** * Execute a specific command in the channel thread. *