diff --git a/net/src/main/java/com/zfoo/net/consumer/balancer/AbstractConsumerLoadBalancer.java b/net/src/main/java/com/zfoo/net/consumer/balancer/AbstractConsumerLoadBalancer.java index fccac580..8834412c 100644 --- a/net/src/main/java/com/zfoo/net/consumer/balancer/AbstractConsumerLoadBalancer.java +++ b/net/src/main/java/com/zfoo/net/consumer/balancer/AbstractConsumerLoadBalancer.java @@ -15,7 +15,6 @@ package com.zfoo.net.consumer.balancer; import com.zfoo.net.NetContext; import com.zfoo.net.consumer.registry.RegisterVO; -import com.zfoo.net.packet.IPacket; import com.zfoo.net.session.Session; import com.zfoo.protocol.ProtocolManager; import com.zfoo.protocol.registration.ProtocolModule; @@ -64,7 +63,7 @@ public abstract class AbstractConsumerLoadBalancer implements IConsumerLoadBalan return list; } - public boolean sessionHasModule(Session session, IPacket packet) { + public boolean sessionHasModule(Session session, Object packet) { var consumerAttribute = session.getConsumerAttribute(); if (Objects.isNull(consumerAttribute)) { return false; diff --git a/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java b/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java index 86b221ea..53d47c40 100644 --- a/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java +++ b/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java @@ -17,7 +17,6 @@ import com.baidu.bjf.remoting.protobuf.Codec; import com.baidu.bjf.remoting.protobuf.ProtobufProxy; import com.zfoo.net.packet.DecodedPacketInfo; import com.zfoo.net.packet.EncodedPacketInfo; -import com.zfoo.net.packet.IPacket; import com.zfoo.net.packet.PacketService; import com.zfoo.protocol.ProtocolManager; import com.zfoo.protocol.buffer.ByteBufUtils; @@ -79,7 +78,7 @@ public class JProtobufTcpCodecHandler extends ByteToMessageCodec