Skip to content

Instantly share code, notes, and snippets.

@dasch
Created Sep 6, 2017
Embed
What would you like to do?
module EventLog
AVRO = AvroTurf.new(schemas_path: "app/schemas/")
def self.publish(event_name, payload = {})
data = AVRO.encode(payload, schema_name: event_name)
DeliveryBoy.deliver(data, topic: event_name)
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment