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