lib/sqewer/connection.rb in sqewer-6.4.0 vs lib/sqewer/connection.rb in sqewer-6.4.1
- old
+ new
@@ -53,11 +53,15 @@
# continue.
#
# @return [Array<Message>] an array of Message objects
def receive_messages
Retriable.retriable on: Seahorse::Client::NetworkingError, tries: MAX_RANDOM_RECEIVE_FAILURES do
- response = client.receive_message(queue_url: @queue_url,
- wait_time_seconds: DEFAULT_TIMEOUT_SECONDS, max_number_of_messages: BATCH_RECEIVE_SIZE)
+ response = client.receive_message(
+ queue_url: @queue_url,
+ attribute_names: ['All'],
+ wait_time_seconds: DEFAULT_TIMEOUT_SECONDS,
+ max_number_of_messages: BATCH_RECEIVE_SIZE
+ )
response.messages.map {|message| Message.new(message.receipt_handle, message.body, message.attributes) }
end
end
# Send a message to the backing queue