Contents

# frozen_string_literal: true

# https://upstash.com/docs/qstash/api/messages/get
module Qstash
  module Message
    class Get
      include Qstash::Callable
      attr_reader :message_id, :headers

      def initialize(message_id, headers: {})
        @message_id = message_id
        @headers = headers
      end

      def call
        uri = URI(endpoint)
        client = Qstash::HttpClient.new(uri)
        client.get(headers)
      end

      private

      def endpoint
        [
          Qstash.config.url.sub(/\/$/, ""),
          Endpoints::GET_ENDPOINT,
          message_id
        ].join("/")
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
qstash-rb-0.1.3	lib/qstash/message/get.rb
qstash-rb-0.1.2	lib/qstash/message/get.rb