Contents

require 'rubygems'
require File.dirname(__FILE__) + '/../init.rb'
RosettaQueue.logger = Logger.new(File.expand_path(File.dirname(__FILE__) + '/../../log/rosetta_queue.log'))

RosettaQueue::Adapter.define do |a|
  a.user      = "rosetta"
  a.password  = "password"
  a.host      = "localhost"
  a.type      = "amqp_synch"
end

RosettaQueue::Destinations.define do |dest|
  dest.map :foo, "fanout.foo"
end


RosettaQueue::Producer.publish(:foo, "hello there")

Version data entries

3 entries across 3 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.3.3	examples/sample_amqp_fanout_producer.rb
rosetta_queue-0.5.0	examples/sample_amqp_fanout_producer.rb
rosetta_queue-0.4.0	examples/sample_amqp_fanout_producer.rb