Merge remote-tracking branch 'origin/main'

This commit is contained in:
sun
2023-03-13 16:05:37 +08:00
4 changed files with 5 additions and 4 deletions
@@ -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;
}
}
@@ -39,12 +39,12 @@ public class EventReceiverDefinition implements IEventReceiver {
// 事件接收方式
private Bus bus;
public EventReceiverDefinition(Object bean, Method method, Class<? extends IEvent> eventClazz, Bus bus) {
public EventReceiverDefinition(Object bean, Method method, Bus bus, Class<? extends IEvent> eventClazz) {
this.bean = bean;
this.method = method;
this.bus = bus;
this.eventClazz = eventClazz;
ReflectionUtils.makeAccessible(this.method);
this.bus = bus;
}
@Override
@@ -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中
@@ -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