diff --git a/server/netty/src/com/riiablo/net/reliable/MessageChannel.java b/server/netty/src/com/riiablo/net/reliable/MessageChannel.java index 333fa441..9b99a94c 100644 --- a/server/netty/src/com/riiablo/net/reliable/MessageChannel.java +++ b/server/netty/src/com/riiablo/net/reliable/MessageChannel.java @@ -26,6 +26,10 @@ public abstract class MessageChannel implements ReliablePacketController.PacketL return sequence = (sequence + 1) & Packet.USHORT_MAX_VALUE; } + protected ReliablePacketController controller() { + return packetController; + } + public abstract void reset(); public abstract void update(float delta, int channelId, DatagramChannel ch); public abstract void sendMessage(int channelId, DatagramChannel ch, ByteBuf bb); diff --git a/server/netty/src/com/riiablo/net/reliable/ReliableEndpoint.java b/server/netty/src/com/riiablo/net/reliable/ReliableEndpoint.java index e232fdf2..45928354 100644 --- a/server/netty/src/com/riiablo/net/reliable/ReliableEndpoint.java +++ b/server/netty/src/com/riiablo/net/reliable/ReliableEndpoint.java @@ -52,6 +52,10 @@ public class ReliableEndpoint implements Endpoint, MessageChanne return channel; } + public MessageChannel channel(int channelId) { + return channels[channelId]; + } + @Override public void reset() { final MessageChannel[] channels = this.channels;