org.axonframework.queryhandling.FluxSinkWrapper to java.util.concurrent.CopyOnWriteArrayList