lambda support for message processors and observers