Contents

# frozen_string_literal: true

require "qstash/message/publish"
require "qstash/message/enqueue"
require "qstash/message/batch"
require "qstash/message/get"
require "qstash/message/cancel"

module Qstash
  module Message
    class << self
      def batch(messages:, headers: {})
        Batch.call(messages: messages, headers: headers)
      end

      def cancel(message_ids, headers: {})
        Cancel.call(message_ids, headers: headers)
      end

      def enqueue(queue_name:, destination:, body:, headers: {})
        Enqueue.call(queue_name: queue_name, destination: destination, body: body, headers: headers)
      end

      def get(message_id, headers: {})
        Get.call(message_id, headers: headers)
      end

      def publish(destination:, body:, headers: {})
        Publish.call(destination: destination, body: body, headers: headers)
      end
    end

    private_constant :Publish, :Enqueue, :Batch, :Get, :Cancel
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

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