def subscribe(&callback)
      redis.subscribe(channel) do |on|
        on.message do |channel, payload|
          data = JSON.parse(payload) rescue payload
          callback.call channel, data, self
        end
      end
    end
def subscribe(&callback)
      redis.subscribe(channel) do |on|
        on.message do |channel, payload|
          data = JSON.parse(payload) rescue payload
          callback.call channel, data, self
        end
      end
    end
Creates a subscription to the given channel
 @param channel [String] The channel to listen to
 @yield The code to execute on a published event
 @yieldparam channel [String] The channel the subscriber is listening to
 @yieldparam data [Object] The event published on the channel
 @yieldparam subscriber [BlockingSubscriber] This instance
 Sets up the Redis pub/sub subscription
 @yield The code to execute on a published event