Module: Rocketman::Producer

Included in:
Relay::Redis
Defined in:
lib/rocketman/producer.rb

Instance Method Summary collapse

Instance Method Details

#emit(event, payload = {}) ⇒ Object 



3
4
5
6
 
# File 'lib/rocketman/producer.rb', line 3

def emit(event, payload = {})
  event = Rocketman::Event.new(event.to_sym, payload)
  Rocketman::Pool.instance.jobs.schedule(event)
end