Environment.initializeIfEmpty()
.assignErrorJournal();
}</BUG>
public static void main(String... args) throws InterruptedException {
<BUG>EventBus r = EventBus.config()

.env(get())
.synchronousDispatcher()
.get();</BUG>
r.on($("/some/topic"), ev -> LOG.info("Got event '{}'", ev.getData()));

import reactor.bus.EventBus;
import static reactor.bus.selector.Selectors.*;
public class SelectorSamples {
static final Logger LOG = LoggerFactory.getLogger(SelectorSamples.class);
public static void main(String... args) throws InterruptedException {
EventBus r = EventBus.create();
r.on($("/some/topic"), ev -> LOG.info("Got event '{}'", ev.getData()));
