Contents

# coding: utf-8

################################################
# © Alexander Semyonov, 2013—2013              #
# Author: Alexander Semyonov <[e-mail]>  #
################################################

require 'synapses'
require 'synapses/contract/definitions'

module Synapses
  # @author Alexander Semyonov <[e-mail]>
  class Producer
    include Contract::Definitions

    def initialize(channel = nil)
      @channel = channel
    end

    def <<(message)
      EventMachine.next_tick do
        exchange.publish(message.to_payload, message.options) do
          puts "published [#{message.to_payload}, #{message.options}]"
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
synapses-0.0.1	lib/synapses/producer.rb