class Eventboss::Sender
Attributes
client[R]
queue[R]
Public Class Methods
new(client:, queue:)
click to toggle source
# File lib/eventboss/sender.rb, line 3 def initialize(client:, queue:) @client = client @queue = queue end
Public Instance Methods
send_batch(payload)
click to toggle source
# File lib/eventboss/sender.rb, line 8 def send_batch(payload) client.send_message_batch( queue_url: queue.url, entries: Array(build_entries(payload)) ) end
Private Instance Methods
build_entries(messages)
click to toggle source
# File lib/eventboss/sender.rb, line 19 def build_entries(messages) messages.map do |message| { id: SecureRandom.hex, message_body: message.to_json } end end