Implement Consumer layer #12
Description
Is your feature request related to a problem? Please describe.
Implement Consumer layer to read messages from queues/streams
Describe the solution you'd like
Have a look to Java/.Net implementation
Describe alternatives you've considered
No response
Additional context
No response