Contents

#!/usr/bin/env ruby

require 'amqp'

EventMachine.run do
  AMQP.connect do |connection|
    channel  = AMQP::Channel.new(connection)
    # topic exchange name can be any string
    exchange = channel.topic('cony-test', durable: true)

    # Subscribers.
    channel.queue('', exclusive: true) do |queue|
      queue.bind(exchange, routing_key: '#').subscribe do |_headers, payload|
        puts payload.inspect
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cony-2.2.5	bin/cony-receive
cony-2.2.4	bin/cony-receive
cony-2.2.3	bin/cony-receive
cony-2.2.2	bin/cony-receive
cony-2.2.1	bin/cony-receive