lib/qstash/message.rb in qstash-rb-0.1.2 vs lib/qstash/message.rb in qstash-rb-0.1.3

- old
+ new

@@ -3,27 +3,22 @@ require "qstash/message/publish" require "qstash/message/enqueue" require "qstash/message/batch" require "qstash/message/get" require "qstash/message/cancel" -require "qstash/message/bulk_cancel" module Qstash module Message class << self def batch(messages:, headers: {}) Batch.call(messages: messages, headers: headers) end - def bulk_cancel(message_ids, headers: {}) - BulkCancel.call(message_ids, headers: headers) + def cancel(message_ids, headers: {}) + Cancel.call(message_ids, headers: headers) end - def cancel(message_id, headers: {}) - Cancel.call(message_id, 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: {}) @@ -33,8 +28,8 @@ def publish(destination:, body:, headers: {}) Publish.call(destination: destination, body: body, headers: headers) end end - private_constant :Publish, :Enqueue, :Batch, :Get, :Cancel, :BulkCancel + private_constant :Publish, :Enqueue, :Batch, :Get, :Cancel end end