public class Event {
}
public class EventHandler implements EventHandler<Event> {
@Override
public void onEvent(Event event, long sequence, boolean endOfBatch) {
}
}
Disruptor<Event> disruptor = new Disruptor<>(Event::new, bufferSize, executor);
disruptor.handleEventsWith(new EventHandler());
disruptor.start();
RingBuffer<Event> ringBuffer = disruptor.getRingBuffer();
long sequence = ringBuffer.next();
Event event = ringBuffer.get(sequence);
ringBuffer.publish(sequence);
