Simplified Stream processing logic
Simplify Stream message processing logic