Moved filtering messages per Process into AwaitableMessageStreamFilter