Class: AzureClient::Queue
- Inherits:
-
Object
- Object
- AzureClient::Queue
- Defined in:
- lib/azure_client/queue.rb
Instance Attribute Summary collapse
-
#name ⇒ Object
Returns the value of attribute name.
Instance Method Summary collapse
- #add_message(content, retry_policy = @retry_policy) ⇒ Object
- #delete(retry_policy = @retry_policy) ⇒ Object
-
#get_message(retry_policy = LinearRetryPolicy.new(1,1)) ⇒ Object
default to only one try.
-
#initialize(name, queue_service, retry_policy = ExponentialRetryPolicy.new(5,1,2)) ⇒ Queue
constructor
A new instance of Queue.
Constructor Details
#initialize(name, queue_service, retry_policy = ExponentialRetryPolicy.new(5,1,2)) ⇒ Queue
Returns a new instance of Queue.
5 6 7 8 9 |
# File 'lib/azure_client/queue.rb', line 5 def initialize(name, queue_service, retry_policy = ExponentialRetryPolicy.new(5,1,2)) @name = name @queue_service = queue_service @retry_policy = retry_policy end |
Instance Attribute Details
#name ⇒ Object
Returns the value of attribute name.
3 4 5 |
# File 'lib/azure_client/queue.rb', line 3 def name @name end |
Instance Method Details
#add_message(content, retry_policy = @retry_policy) ⇒ Object
11 12 13 14 15 16 |
# File 'lib/azure_client/queue.rb', line 11 def (content, retry_policy = @retry_policy) retry_policy.retry { encoded = Base64.encode64(content) @queue_service.(name, encoded) } end |
#delete(retry_policy = @retry_policy) ⇒ Object
26 27 28 29 30 |
# File 'lib/azure_client/queue.rb', line 26 def delete(retry_policy = @retry_policy) retry_policy.retry { @queue_service.delete_queue(name) } end |
#get_message(retry_policy = LinearRetryPolicy.new(1,1)) ⇒ Object
default to only one try
19 20 21 22 23 24 |
# File 'lib/azure_client/queue.rb', line 19 def (retry_policy = LinearRetryPolicy.new(1,1)) retry_policy.retry { = @queue_service.(name, 30).first ? Message.new(, name, @queue_service, @retry_policy) : nil } end |