class Synapses::Producer
@author Alexander Semyonov <al@semyonov.us>
Public Class Methods
new(channel = nil)
click to toggle source
# File lib/synapses/producer.rb, line 16 def initialize(channel = nil) @channel = channel end
Public Instance Methods
<<(message)
click to toggle source
# File lib/synapses/producer.rb, line 20 def <<(message) EventMachine.next_tick do exchange.publish(message.to_payload, message.options) do puts "published [#{message.to_payload}, #{message.options}]" end end end