// Path: src/main/java/com/viadeo/axonframework/eventhandling/cluster/ClusterSelectorFactory.java
// public interface ClusterSelectorFactory {
//     ClusterSelector create();
// }


import com.google.common.collect.Lists;
import com.viadeo.axonframework.eventhandling.cluster.ClusterSelectorFactory;
import com.viadeo.axonframework.eventhandling.terminal.kafka.*;
import org.axonframework.domain.EventMessage;
import org.axonframework.eventhandling.ClusteringEventBus;
import org.axonframework.eventhandling.EventBus;
import org.axonframework.eventhandling.EventBusTerminal;
import org.axonframework.eventhandling.EventListener;
import org.junit.rules.ExternalResource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.Closeable;
import java.io.IOException;
import java.util.List;
import java.util.UUID;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
package com.viadeo.axonframework.eventhandling;




public class TestEventBus extends ExternalResource {

    private static final Logger LOGGER = LoggerFactory.getLogger(TestEventBus.class);

    private final KafkaTerminalFactory terminalFactory;
// Path: src/main/java/com/viadeo/axonframework/eventhandling/cluster/ClusterSelectorFactory.java
// public interface ClusterSelectorFactory {
//     ClusterSelector create();
// }


// Path: src/test/java/com/viadeo/axonframework/eventhandling/TestEventBus.java
import com.google.common.collect.Lists;
import com.viadeo.axonframework.eventhandling.cluster.ClusterSelectorFactory;
import com.viadeo.axonframework.eventhandling.terminal.kafka.*;
import org.axonframework.domain.EventMessage;
import org.axonframework.eventhandling.ClusteringEventBus;
import org.axonframework.eventhandling.EventBus;
import org.axonframework.eventhandling.EventBusTerminal;
import org.axonframework.eventhandling.EventListener;
import org.junit.rules.ExternalResource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.Closeable;
import java.io.IOException;
import java.util.List;
import java.util.UUID;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;

package com.viadeo.axonframework.eventhandling;




public class TestEventBus extends ExternalResource {

    private static final Logger LOGGER = LoggerFactory.getLogger(TestEventBus.class);

    private final KafkaTerminalFactory terminalFactory;
    private final ClusterSelectorFactory clusterSelectorFactory;