using Google.Protobuf; using Google.Protobuf.WellKnownTypes; using ServerCore; using ServerBase; using ServerCommon; using ServerCommon.BusinessLogDomain; using MetaAssets; namespace GameServer.PacketHandler; [PacketHandler("", typeof(ServerMessage.Types.PartyInstanceInfoNoti), typeof(NtfPartyInstanceInfoMQPacketHandler), typeof(RabbitMQ4Game))] public class NtfPartyInstanceInfoMQPacketHandler : PacketRecvHandler { public override async Task onProcessPacket(ISession session, IMessage recvMessage) { var msg = recvMessage as ServerMessage; ArgumentNullException.ThrowIfNull(msg); Log.getLogger().info($"HandlePartyInstanceInfoNoti"); var handler = new NotifyPartyInstanceHandler(); await handler.recvPartyInstance(msg.PartyInstanceInfoNoti); return new(); } }