diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java index b9dce498..b9b09c79 100644 --- a/event/src/main/java/com/zfoo/event/manager/EventBus.java +++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java @@ -110,6 +110,7 @@ public abstract class EventBus { execute(event.executorHash(), () -> doReceiver(receiver, event)); break; case VirtualThread: + logger.error("waiting for java 21 virtual thread"); break; } } 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中 diff --git a/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java b/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java index 4d90504a..7de58db3 100644 --- a/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java +++ b/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java @@ -48,7 +48,7 @@ public class SignalAttachment implements IAttachment { /** * The time the client sent it */ - private transient long timestamp = TimeUtils.now(); + private long timestamp = TimeUtils.now(); /** * EN:The method of callback when the client receives a reply from the server