using DotNetty.Transport.Channels; using HybirdFrameworkCore.Autofac.Attribute; using HybirdFrameworkCore.Utils; using log4net; using Newtonsoft.Json; using Service.Charger.Client; using Service.Charger.Msg.Charger.Req; using Service.Charger.Msg.Charger.Resp; namespace Service.Charger.Handler; /// /// 移库完成 处理器 /// [Order(8)] [Scope("InstancePerDependency")] public class MigrationCompleteReqHandler : SimpleChannelInboundHandler, IBaseHandler { /// /// /// private static readonly ILog Log = LogManager.GetLogger(typeof(MigrationCompleteReqHandler)); /// /// /// protected override void ChannelRead0(IChannelHandlerContext ctx, MigrationCompleteReq msg) { Log.Info("swap finish"); ctx.Channel.WriteAndFlushAsync(message: new Msg.Host.Resp.MigrationCompleteResq()); } }