Skip to content

Commit

Permalink
Remove unused methods
Browse files Browse the repository at this point in the history
  • Loading branch information
eagletmt committed Jul 21, 2017
1 parent a397414 commit 5cdb950
Showing 1 changed file with 0 additions and 14 deletions.
14 changes: 0 additions & 14 deletions lib/barbeque/message_queue.rb
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,6 @@

module Barbeque
class MessageQueue
class ExtendVisibilityError < StandardError
end

attr_reader :job_queue

def initialize(queue_name)
Expand Down Expand Up @@ -57,17 +54,6 @@ def receive_message
end
end

def extend_visibility_timeout(messages)
resp = client.change_message_visibility_batch(
queue_url: @job_queue.queue_url,
entries: messages.map { |message| { id: message.message_id, receipt_handle: message.receipt_handle, visibility_timeout: 60 } },
)
unless resp.failed.empty?
raise "Failed to extend visibility timeout: #{resp.failed.map(&:inspect)}"
end
nil
end

def client
@client ||= Aws::SQS::Client.new
end
Expand Down

0 comments on commit 5cdb950

Please sign in to comment.