Class: Sqewer::Connection::SendBuffer
- Inherits:
-
MessageBuffer
- Object
- Struct
- MessageBuffer
- Sqewer::Connection::SendBuffer
- Defined in:
- lib/sqewer/connection.rb
Overview
Saves the messages to send to the SQS queue
Constant Summary
Constants inherited from MessageBuffer
Instance Attribute Summary
Attributes inherited from MessageBuffer
Instance Method Summary collapse
Methods inherited from MessageBuffer
Constructor Details
This class inherits a constructor from Sqewer::Connection::MessageBuffer
Instance Method Details
#send_message(message_body, **kwargs_for_send) ⇒ Object
76 77 78 79 80 81 82 |
# File 'lib/sqewer/connection.rb', line 76 def (, **kwargs_for_send) # The "id" is only valid _within_ the request, and is used when # an error response refers to a specific ID within a batch m = {message_body: , id: .length.to_s} m[:delay_seconds] = kwargs_for_send[:delay_seconds] if kwargs_for_send[:delay_seconds] << m end |