in src/main/java/deltix/ember/sample/JournalReaderSample.java [12:21]
public static void main (String [] args) {
final Config config = EmberConfig.load();
final Consumer<Object> consumer = (message) -> System.out.println(message);
try (final EmberBinaryJournalReader reader = EmberAppHelper.createObjectJournalReader(config)) {
// read each message using provided consumer
while (reader.read(consumer)) ;
}
}