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
87 88 89 90 91 92 93 |
# File 'lib/sqewer/connection.rb', line 87 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 |