Sha256: a14425157d00eda02cebf0705f3542d4b619453866c7be6d50bca580f09dbe3f
Contents?: true
Size: 586 Bytes
Versions: 45
Compression:
Stored size: 586 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Core
module Monitoring
# Single notification event wrapping payload with id
class Event
attr_reader :id, :payload
# @param id [String, Symbol] id of the event
# @param payload [Hash] event payload
def initialize(id, payload)
@id = id
@payload = payload
end
# Hash access to the payload data (if present)
#
# @param [String, Symbol] name
def [](name)
@payload.fetch(name)
end
end
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems