fix:事件驱动bug

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;
+    }
 }

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