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