Class: Toiler::Gcp::Message
- Inherits:
-
Object
- Object
- Toiler::Gcp::Message
- Defined in:
- lib/toiler/gcp/message.rb
Overview
PubSub Message abstraction Provides methods for querying and acting on a PubSub message
Instance Attribute Summary collapse
-
#message ⇒ Object
Returns the value of attribute message.
Instance Method Summary collapse
- #ack_id ⇒ Object
- #attributes ⇒ Object
- #body ⇒ Object
- #delete ⇒ Object
- #delivery_attempt ⇒ Object
-
#initialize(message) ⇒ Message
constructor
A new instance of Message.
- #message_id ⇒ Object
- #modify_ack_deadline!(timeout) ⇒ Object
- #ordering_key ⇒ Object
- #published_at ⇒ Object
- #reject! ⇒ Object
Constructor Details
#initialize(message) ⇒ Message
Returns a new instance of Message.
10 11 12 |
# File 'lib/toiler/gcp/message.rb', line 10 def initialize() @message = end |
Instance Attribute Details
#message ⇒ Object
Returns the value of attribute message.
8 9 10 |
# File 'lib/toiler/gcp/message.rb', line 8 def @message end |
Instance Method Details
#ack_id ⇒ Object
50 51 52 |
# File 'lib/toiler/gcp/message.rb', line 50 def ack_id .ack_id end |
#attributes ⇒ Object
30 31 32 |
# File 'lib/toiler/gcp/message.rb', line 30 def attributes .attributes end |
#body ⇒ Object
26 27 28 |
# File 'lib/toiler/gcp/message.rb', line 26 def body .data end |
#delete ⇒ Object
14 15 16 |
# File 'lib/toiler/gcp/message.rb', line 14 def delete .acknowledge! end |
#delivery_attempt ⇒ Object
34 35 36 |
# File 'lib/toiler/gcp/message.rb', line 34 def delivery_attempt .delivery_attempt end |
#message_id ⇒ Object
22 23 24 |
# File 'lib/toiler/gcp/message.rb', line 22 def . end |
#modify_ack_deadline!(timeout) ⇒ Object
18 19 20 |
# File 'lib/toiler/gcp/message.rb', line 18 def modify_ack_deadline!(timeout) .modify_ack_deadline! timeout end |
#ordering_key ⇒ Object
38 39 40 |
# File 'lib/toiler/gcp/message.rb', line 38 def ordering_key .ordering_key end |
#published_at ⇒ Object
46 47 48 |
# File 'lib/toiler/gcp/message.rb', line 46 def published_at .published_at end |
#reject! ⇒ Object
42 43 44 |
# File 'lib/toiler/gcp/message.rb', line 42 def reject! .reject! end |