Class: Aws::SQS::Queue
- Inherits:
-
Object
- Object
- Aws::SQS::Queue
- Extended by:
- Deprecations
- Defined in:
- lib/aws-sdk-sqs/queue.rb
Defined Under Namespace
Classes: Collection
Read-Only Attributes collapse
-
#attributes ⇒ Hash<String,String>
A map of attributes to their respective values.
- #url ⇒ String
Actions collapse
- #add_permission(options = {}) ⇒ EmptyStructure
- #change_message_visibility_batch(options = {}) ⇒ Types::ChangeMessageVisibilityBatchResult
- #delete(options = {}) ⇒ EmptyStructure
- #delete_messages(options = {}) ⇒ Types::DeleteMessageBatchResult
- #purge(options = {}) ⇒ EmptyStructure
- #receive_messages(options = {}) ⇒ Message::Collection
- #remove_permission(options = {}) ⇒ EmptyStructure
- #send_message(options = {}) ⇒ Types::SendMessageResult
- #send_messages(options = {}) ⇒ Types::SendMessageBatchResult
- #set_attributes(options = {}) ⇒ EmptyStructure
Associations collapse
- #dead_letter_source_queues(options = {}) ⇒ Queue::Collection
- #identifiers ⇒ Object deprecated private Deprecated.
- #message(receipt_handle) ⇒ Message
Instance Method Summary collapse
- #client ⇒ Client
-
#data ⇒ Types::GetQueueAttributesResult
Returns the data for this Queue.
-
#data_loaded? ⇒ Boolean
Returns ‘true` if this resource is loaded.
-
#initialize(*args) ⇒ Queue
constructor
A new instance of Queue.
- #load ⇒ self (also: #reload)
Constructor Details
#initialize(url, options = {}) ⇒ Queue #initialize(options = {}) ⇒ Queue
Returns a new instance of Queue.
19 20 21 22 23 24 |
# File 'lib/aws-sdk-sqs/queue.rb', line 19 def initialize(*args) = Hash === args.last ? args.pop.dup : {} @url = extract_url(args, ) @data = .delete(:data) @client = .delete(:client) || Client.new() end |
Instance Method Details
#add_permission(options = {}) ⇒ EmptyStructure
121 122 123 124 125 |
# File 'lib/aws-sdk-sqs/queue.rb', line 121 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#attributes ⇒ Hash<String,String>
A map of attributes to their respective values.
35 36 37 |
# File 'lib/aws-sdk-sqs/queue.rb', line 35 def attributes data[:attributes] end |
#change_message_visibility_batch(options = {}) ⇒ Types::ChangeMessageVisibilityBatchResult
143 144 145 146 147 |
# File 'lib/aws-sdk-sqs/queue.rb', line 143 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#data ⇒ Types::GetQueueAttributesResult
Returns the data for this Aws::SQS::Queue. Calls Client#get_queue_attributes if #data_loaded? is ‘false`.
65 66 67 68 |
# File 'lib/aws-sdk-sqs/queue.rb', line 65 def data load unless @data @data end |
#data_loaded? ⇒ Boolean
73 74 75 |
# File 'lib/aws-sdk-sqs/queue.rb', line 73 def data_loaded? !!@data end |
#dead_letter_source_queues(options = {}) ⇒ Queue::Collection
695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 |
# File 'lib/aws-sdk-sqs/queue.rb', line 695 def dead_letter_source_queues( = {}) batches = Enumerator.new do |y| batch = [] = .merge(queue_url: @url) resp = @client.list_dead_letter_source_queues() resp.data.queue_urls.each do |q| batch << Queue.new( url: q, client: @client ) end y.yield(batch) end Queue::Collection.new(batches) end |
#delete(options = {}) ⇒ EmptyStructure
154 155 156 157 158 |
# File 'lib/aws-sdk-sqs/queue.rb', line 154 def delete( = {}) = .merge(queue_url: @url) resp = @client.delete_queue() resp.data end |
#delete_messages(options = {}) ⇒ Types::DeleteMessageBatchResult
174 175 176 177 178 |
# File 'lib/aws-sdk-sqs/queue.rb', line 174 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#identifiers ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
Deprecated.
723 724 725 |
# File 'lib/aws-sdk-sqs/queue.rb', line 723 def identifiers { url: @url } end |
#load ⇒ self Also known as: reload
Loads, or reloads #data for the current Aws::SQS::Queue. Returns ‘self` making it possible to chain methods.
queue.reload.data
52 53 54 55 56 57 58 59 |
# File 'lib/aws-sdk-sqs/queue.rb', line 52 def load resp = @client.get_queue_attributes( queue_url: @url, attribute_names: ["All"] ) @data = resp.data self end |
#message(receipt_handle) ⇒ Message
713 714 715 716 717 718 719 |
# File 'lib/aws-sdk-sqs/queue.rb', line 713 def (receipt_handle) Message.new( queue_url: @url, receipt_handle: receipt_handle, client: @client ) end |
#purge(options = {}) ⇒ EmptyStructure
185 186 187 188 189 |
# File 'lib/aws-sdk-sqs/queue.rb', line 185 def purge( = {}) = .merge(queue_url: @url) resp = @client.purge_queue() resp.data end |
#receive_messages(options = {}) ⇒ Message::Collection
337 338 339 340 341 342 343 344 345 346 347 348 349 350 |
# File 'lib/aws-sdk-sqs/queue.rb', line 337 def ( = {}) batch = [] = .merge(queue_url: @url) resp = @client.() resp.data..each do |m| batch << Message.new( queue_url: @url, receipt_handle: m.receipt_handle, data: m, client: @client ) end Message::Collection.new([batch], size: batch.size) end |
#remove_permission(options = {}) ⇒ EmptyStructure
362 363 364 365 366 |
# File 'lib/aws-sdk-sqs/queue.rb', line 362 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#send_message(options = {}) ⇒ Types::SendMessageResult
515 516 517 518 519 |
# File 'lib/aws-sdk-sqs/queue.rb', line 515 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#send_messages(options = {}) ⇒ Types::SendMessageBatchResult
547 548 549 550 551 |
# File 'lib/aws-sdk-sqs/queue.rb', line 547 def ( = {}) = .merge(queue_url: @url) resp = @client.() resp.data end |
#set_attributes(options = {}) ⇒ EmptyStructure
682 683 684 685 686 |
# File 'lib/aws-sdk-sqs/queue.rb', line 682 def set_attributes( = {}) = .merge(queue_url: @url) resp = @client.set_queue_attributes() resp.data end |
#url ⇒ String
29 30 31 |
# File 'lib/aws-sdk-sqs/queue.rb', line 29 def url @url end |