Subscriber: add the option to run callback in a separate thread.
When a message arrives, instead of being executed immediately it is pushed into a queue where a separate worker will fetch and execute it.
Add a new utility class QueueConsumer that waits on a queue for new data to be processed and when new data arrives call the user-provided callback on the data.
Description
Subscriber: add the option to run callback in a separate thread. When a message arrives, instead of being executed immediately it is pushed into a queue where a separate worker will fetch and execute it.
Add a new utility class
QueueConsumerthat waits on a queue for new data to be processed and when new data arrives call the user-provided callback on the data.