Reactive redis pub/sub example