Enforce downstream transformations on message streams