From 3dc399395c79bd036e676d551069b12d55f3368f Mon Sep 17 00:00:00 2001
From: "le.kuang" <1741461577@qq.com>
Date: Thu, 9 Feb 2023 21:01:57 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BA=8B=E4=BB=B6=E9=A9=B1=E5=8A=A8bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq/springeventbus/SpringEventBusEvent.java | 18 ++++++++++++++++++
 .../SpringEventBusSendMqServiceImpl.java       |  6 +-----
 2 files changed, 19 insertions(+), 5 deletions(-)

diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusEvent.java b/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusEvent.java
index 08f2807..6ab6397 100644
--- a/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusEvent.java
+++ b/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusEvent.java
@@ -15,4 +15,22 @@ public class SpringEventBusEvent extends ApplicationEvent {
     public String jsonValue;
     public String tagId;
 
+    public SpringEventBusEvent(Object source, String topic, String jsonValue, String tagId) {
+        super(source);
+        this.topic = topic;
+        this.jsonValue = jsonValue;
+        this.tagId = tagId;
+    }
+
+    public String getTopic() {
+        return topic;
+    }
+
+    public String getJsonValue() {
+        return jsonValue;
+    }
+
+    public String getTagId() {
+        return tagId;
+    }
 }
diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusSendMqServiceImpl.java b/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusSendMqServiceImpl.java
index 05f8e1b..3703192 100644
--- a/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusSendMqServiceImpl.java
+++ b/austin-support/src/main/java/com/java3y/austin/support/mq/springeventbus/SpringEventBusSendMqServiceImpl.java
@@ -25,11 +25,7 @@ public class SpringEventBusSendMqServiceImpl implements SendMqService {
 
     @Override
     public void send(String topic, String jsonValue, String tagId) {
-        SpringEventBusEvent springEventBusEvent = new SpringEventBusEvent();
-        springEventBusEvent.setTopic(topic);
-        springEventBusEvent.setJsonValue(jsonValue);
-        springEventBusEvent.setTagId(tagId);
-        applicationContext.publishEvent(springEventBusEvent);
+        applicationContext.publishEvent(new SpringEventBusEvent(this, topic, jsonValue, tagId));
     }
 
     @Override