1. Add support for `SSUBSCRIBE` and `SUNSUBSCRIBE` commands. 2. Update `PubSubConsumer` to be able to consume from shard channels. 3. Update `DispatcherLoop` to be able to consume messages from shard channels and execute callbacks. 4. Unit tests coverage