@Test
public void testRideEventBus() throws Exception {

	EventBus evtBus = new AsyncEventBus(Executors.newFixedThreadPool(numSubscribers));
	for (int i = 1; i <= numSubscribers; i++) {
		evtBus.register(new MarketDataSubscriber());
	}
	MarketEventCallback<String> callback = new MarketEventHandlerImpl<String>(evtBus);
	callback.onMarketEvent(new TradeableInstrument<String>(gbpusd), bid, ask, DateTime.now());
	done.await();
}