Threaded IngestorService based on each currencyMarket for an Exchange.
Enforces fairness for each market and now prevents other markets from
getting delayed to one slow call to another market.