IBLevel2QuoteProcessor extends IBQuoteProcessor<Level2QuoteData> { public void removeTicker( Ticker ticker ) { bidBookMap.remove(ticker); askBookMap.remove(ticker); } IBLevel2QuoteProcessor(BlockingQueue<Level2QuoteData> queue, IQuoteEngine quoteEngine); void removeTicker( Ticker ticker );  }
@Test public void testRemoveTicker() { MockIBLevel2QuoteProcessor processor = buildQuoteProcessor(); Ticker ticker = getCurrencyTicker(); IMarketDepthBook bidBook = MarketDepthBook.newInstance(); IMarketDepthBook askBook = MarketDepthBook.newInstance(); processor.bidBookMap.put(ticker, bidBook); processor.askBookMap.put(ticker, askBook); assertEquals(1, processor.bidBookMap.size()); assertEquals(1, processor.askBookMap.size()); processor.removeTicker(ticker); assertTrue(processor.bidBookMap.isEmpty()); assertTrue(processor.askBookMap.isEmpty()); }