Reactor pattern test for message processing