我有一个具有 com.google.common.event.disuptor.EventDisruptor 的项目源,但我找不到有关此的内容。这是来自 disuptor 的吗?
import com.google.common.domain.message.DomainEventHandler;
import com.google.common.event.disuptor.EventDisruptor;
....
@Consumer("receivePayOrderState")
public class ReceivePayOrderState implements DomainEventHandler {
private final Logger logger = LoggerFactory.getLogger(ReceivePayOrderState.class);
private final Logger biLogger = LoggerFactory.getLogger("sms_order_bi");
private int maxOrderMoney;
@Override
public void onEvent(EventDisruptor event, boolean endOfBatch) throws Exception {
PayOrder payOrder = (PayOrder) event.getDomainMessage().getEventSource();
}
}