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