@Before
public void setUp() {
- ListeningExecutorService executor = MoreExecutors.sameThreadExecutor();
+ ListeningExecutorService executor = MoreExecutors.newDirectExecutorService();
BindingBrokerTestFactory factory = new BindingBrokerTestFactory();
factory.setExecutor(executor);
factory.setStartWithParsedSchema(getStartWithSchema());