I have a process in my microservice, which emits messages and publish them into a redis channel. These messages are consumed by the other microservice, but at the same time they have to be sent via websockets to the browser application. Currently, I have to send the messages from the emitter into two places: the redis channel and centrifugo server via http.

Would be great to have an option to directly consume messages from redis channels or to somehow write such an extension.