Add custom producer for handling incoming messages

- It guards for correct magic bytes.
- Asks for the precise bytes expected.
- Ignores incorrect input and resumes listening.