class PrintStreamMessageLogger implements MessageListener {

    @Override
    public void onProcessingStarted(Object actor, Object message) {
        currentActor.set(actor);
        logMessage(INCOMING_MESSAGE, message);
    }

    public  PrintStreamMessageLogger(PrintStream out);

}