Sha256: 384e984659dfb475a3a4f844f7a2e3e5b2d507bb3a44ba6b5acd7f8dc708ef03
Contents?: true
Size: 478 Bytes
Versions: 27
Compression:
Stored size: 478 Bytes
Contents
module Eventboss
class Sender
def initialize(client:, queue:)
@client = client
@queue = queue
end
def send_batch(payload)
client.send_message_batch(
queue_url: queue.url,
entries: Array(build_entries(payload))
)
end
private
attr_reader :queue, :client
def build_entries(messages)
messages.map do |message|
{ id: SecureRandom.hex, message_body: message.to_json }
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems