class EventBusSource {

    PublisherBuilder<? extends Message<?>> source() {
        MessageConsumer<Message<?>> consumer = vertx.eventBus().consumer(address);
        Multi<io.vertx.mutiny.core.eventbus.Message<Message<?>>> multi = consumer.toMulti();
        if (broadcast) {
            multi = multi.broadcast().toAllSubscribers();
        }
        return ReactiveStreams.fromPublisher(multi)
                .map(this::adapt);
    }

      EventBusSource(Vertx vertx, VertxEventBusConnectorIncomingConfiguration config);

}