diff --git a/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java b/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java index 36e46644..0960c3e1 100644 --- a/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java +++ b/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java @@ -39,12 +39,12 @@ public class EventReceiverDefinition implements IEventReceiver { // 事件接收方式 private Bus bus; - public EventReceiverDefinition(Object bean, Method method, Class eventClazz, Bus bus) { + public EventReceiverDefinition(Object bean, Method method, Bus bus, Class eventClazz) { this.bean = bean; this.method = method; + this.bus = bus; this.eventClazz = eventClazz; ReflectionUtils.makeAccessible(this.method); - this.bus = bus; } @Override diff --git a/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java b/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java index 6e450dfa..d8ebf9b9 100644 --- a/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java +++ b/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java @@ -80,7 +80,7 @@ public class EventRegisterProcessor implements BeanPostProcessor { } var bus = method.getDeclaredAnnotation(EventReceiver.class).value(); - var receiverDefinition = new EventReceiverDefinition(bean, method, eventClazz, bus); + var receiverDefinition = new EventReceiverDefinition(bean, method, bus, eventClazz); var enhanceReceiverDefinition = EnhanceUtils.createEventReceiver(receiverDefinition); // key:class类型 value:观察者 注册Event的receiverMap中