retry.rb

# publish_for_retry({"condition" => message["retry_count"] < 3, "message" => {}})

    def publish_for_retry(details)
      if details["condition"]
        publish(details["message"])
      else
        yield
      end
    end

    def publish(message)
      response = client.send(message)
      if response.status == 200
        "successful"
      else
        "error"
      end
    end