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