def pubsub_publish(pipe, message)
        channel = redis_key("channel", pipe)
        redis_connection("redis") do |connection|
          connection.publish(channel, message) do |subscribers|
            info = {:subscribers => subscribers}