def list_publish(pipe, message)
        list = redis_key("list", pipe)
        redis_connection("redis") do |connection|
          connection.rpush(list, message) do |queued|
            info = {:queued => queued}