I got a project source that has com.google.common.event.disuptor.EventDisruptor,but I cannot found something about this.Is this from the 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();
}
}
All classes from the disruptor are under com.lmax.disruptor
. So not its not part of the disruptor. Versions 2.7 to 2.10 were hosted on google code and were published with a maven group id of com.googlecode.disruptor
however the actual packages were com.lmax.disruptor
.
Poking around grepcode as suggested by S.R.I it looks like the jdonframework is your answer