MessageProcessor processor = Util.createMessageProcessor();
        MessageArchiver archiver = Util.createMessageArchiver();
        List<Message> messages = new ArrayList<>(Util.EXPECTED_TOTAL);
        Predicate<Message> p = (x) -> x.getSubject().startsWith("A");
        for (int i = 0; i < Util.EXPECTED_TOTAL; i++) {
            Message msg = Util.random();
            processor.processMessage(msg);
            if(p.test(msg)) {
            	messages.add(msg);
            }
        }


        archiver.archiveMessages(messages, p);