Sha256: 9a51e689d9ce9d1d3677eb7213f4d6210e1bb528e044bb9ad8e7ad6fd0c0849b
Contents?: true
Size: 619 Bytes
Versions: 48
Compression:
Stored size: 619 Bytes
Contents
require 'flydata-core/event/flydata_event'
module FlydataCore
module Event
class FlydataEventSender
def send_event(noun, verb, params = {})
params ||= {}
routing_key = params[:routing_key] || 'default'
event = FlydataEvent.new(noun, verb, params)
send(event, routing_key)
end
protected
def send(event, routing_key)
raise "send method not implemented"
end
end
class SimpleEventSender <FlydataEventSender
protected
def send(event, routing_key)
FlydataEventProcessor.process(event)
end
end
end
end
Version data entries
48 entries across 48 versions & 1 rubygems