@Test
@SuppressWarnings("unchecked")
public void testSendAndMultipleConsumers() {

    String topic = UUID.randomUUID().toString();
    AtomicInteger expected1 = new AtomicInteger(0);
    usage.consumeStrings(topic, 5, 10, TimeUnit.SECONDS,
            v -> expected1.getAndIncrement());
    AtomicInteger expected2 = new AtomicInteger(0);
    usage.consumeStrings(topic, 5, 10, TimeUnit.SECONDS,
            v -> expected2.getAndIncrement());
    Map<String, Object> config = new HashMap<>();
    config.put("address", topic);
    config.put("publish", false);
    EventBusSink sink = new EventBusSink(vertx,
            new VertxEventBusConnectorOutgoingConfiguration(new MapBasedConfig(config)));
    SubscriberBuilder<? extends Message<?>, Void> subscriber = sink.sink();
    Multi.createFrom().range(0, 10)
            .map(i -> Integer.toString(i))
            .map(Message::of)
            .subscribe((Subscriber<Message<?>>) subscriber.build());
    await().untilAtomic(expected1, is(5));
    await().untilAtomic(expected2, is(5));
    assertThat(expected1).hasValueBetween(4, 6);
    assertThat(expected2).hasValueBetween(4, 6);
}