@Override public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception { try { for (PacketListener listener : packetListeners) { msg = listener.onPacketOutAsync(player, ctx.channel(), msg); } } catch (Exception e) { plugin.getLogger().log(Level.SEVERE, "Error in onPacketOutAsync().", e); } if (msg != null) { super.write(ctx, msg, promise); } }
@Override public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception { try { for(PacketListener pl : protocolsListeners) msg = pl.onPacketOutAsync(player, ctx.channel(), msg); } catch (Exception e) { plugin.getLogger().log(Level.SEVERE, "Error in onPacketOutAsync().", e); } if (msg != null) { super.write(ctx, msg, promise); } }