IBQuoteErrorProcessor extends IBQuoteProcessor<QuoteError> { @Override protected void processData(QuoteError error) { quoteEngine.fireErrorEvent(error); } IBQuoteErrorProcessor(BlockingQueue<QuoteError> queue, IQuoteEngine quoteEngine);   }
@Test public void testProcessError() { final IQuoteEngine mockQuoteEngine = mockery.mock( IQuoteEngine.class ); IBQuoteErrorProcessor procesor = new IBQuoteErrorProcessor(null, mockQuoteEngine); final QuoteError error = new QuoteError("foo"); mockery.checking( new Expectations() {{ one(mockQuoteEngine).fireErrorEvent(error); }}); procesor.processData(error); mockery.assertIsSatisfied(); }