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