Class: Toiler::Gcp::Queue
- Inherits:
-
Object
- Object
- Toiler::Gcp::Queue
- Defined in:
- lib/toiler/gcp/queue.rb
Overview
GCP PubSub Queue abstraction Provides methods for querying and acting on a PubSub queue
Instance Attribute Summary collapse
-
#name ⇒ Object
Returns the value of attribute name.
-
#subscription ⇒ Object
Returns the value of attribute subscription.
Instance Method Summary collapse
- #ack_deadline ⇒ Object
- #delete_messages(messages) ⇒ Object
-
#initialize(name, client) ⇒ Queue
constructor
A new instance of Queue.
- #max_messages ⇒ Object
- #receive_messages(wait: nil, max_messages: nil) ⇒ Object
Constructor Details
#initialize(name, client) ⇒ Queue
Returns a new instance of Queue.
12 13 14 15 |
# File 'lib/toiler/gcp/queue.rb', line 12 def initialize(name, client) @name = name @subscription = client.subscription name, skip_lookup: true end |
Instance Attribute Details
#name ⇒ Object
Returns the value of attribute name.
10 11 12 |
# File 'lib/toiler/gcp/queue.rb', line 10 def name @name end |
#subscription ⇒ Object
Returns the value of attribute subscription.
10 11 12 |
# File 'lib/toiler/gcp/queue.rb', line 10 def subscription @subscription end |
Instance Method Details
#ack_deadline ⇒ Object
17 18 19 |
# File 'lib/toiler/gcp/queue.rb', line 17 def ack_deadline subscription.deadline end |
#delete_messages(messages) ⇒ Object
21 22 23 |
# File 'lib/toiler/gcp/queue.rb', line 21 def () subscription.acknowledge() end |
#max_messages ⇒ Object
25 26 27 28 |
# File 'lib/toiler/gcp/queue.rb', line 25 def # pubsub limit is 1000, but it makes little sense to pull so many messages at once 100 end |