From 28c904076a8c7be448425880ddbb900730b43e27 Mon Sep 17 00:00:00 2001 From: HuangXin Date: Sun, 20 Aug 2023 12:23:12 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E7=BD=91=E7=BB=9C=E6=8E=A5=E6=94=B6?= =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E5=A2=9E=E5=8A=A0taskId=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adapter/impl/netty/MessageHandler.java | 1 + .../adapter/impl/netty/notify/SocketNotifyEvent.java | 10 ++++++++++ 2 files changed, 11 insertions(+) diff --git a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java index 817e9ff..f453b52 100644 --- a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java +++ b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/MessageHandler.java @@ -53,6 +53,7 @@ public class MessageHandler extends SimpleChannelInboundHandler message) throws Exception { SocketNotifyEvent notify = new SocketNotifyEvent(this, ctx.channel(), + message.getCommandId(), SocketEventName.SOCKET_EVT_RECV, message.getMsgContent().getMsgBody()); applicationEventPublisher.publishEvent(notify); diff --git a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/notify/SocketNotifyEvent.java b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/notify/SocketNotifyEvent.java index 5748a47..d73432e 100644 --- a/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/notify/SocketNotifyEvent.java +++ b/src/main/java/com/zjyr/beidouservice/adapter/impl/netty/notify/SocketNotifyEvent.java @@ -12,6 +12,7 @@ import org.springframework.context.ApplicationEvent; @Setter @Getter public class SocketNotifyEvent extends ApplicationEvent { + private int taskId; /** * The Evt message. */ @@ -33,10 +34,19 @@ public class SocketNotifyEvent extends ApplicationEvent { * @param evtType the evt type * @param evtMessage the evt message */ + public SocketNotifyEvent(Object source, Channel ctx, int taskId, SocketEventName evtType, Object evtMessage) { + super(source); + this.socketEvent = evtType; + this.evtMessage = evtMessage; + this.ctxChannel = ctx; + this.taskId = taskId; + } + public SocketNotifyEvent(Object source, Channel ctx, SocketEventName evtType, Object evtMessage) { super(source); this.socketEvent = evtType; this.evtMessage = evtMessage; this.ctxChannel = ctx; + this.taskId = 0; } }