@Test
public void testMessageStreamingExtraction() throws Exception {

    File testFile = setUpTestFile();
    FIXMessageDecoder decoder = new FIXMessageDecoder();
    final List<String> messages = new ArrayList<>();
    decoder.extractMessages(testFile, messages::add);
    assertCorrectlyExtractedMessages(messages);
}