Sha256: 512fd7fce717d75b9e9714bb56016e031196770c1cc11fada4e791c3ec266157
Contents?: true
Size: 638 Bytes
Versions: 4
Compression:
Stored size: 638 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "bundler" Bundler.setup $:.unshift(File.expand_path("../../lib", __FILE__)) require 'amqp' EventMachine.run do AMQP.connect(:host => 'localhost') do |connection| puts "Connected to AMQP broker" channel = AMQP::Channel.new(connection) queue = channel.queue("amqpgem.examples.hello_world") exchange = channel.default_exchange queue.subscribe do |payload| puts "Received a message: #{payload}. Disconnecting..." connection.close { EM.stop { exit } } end exchange.publish "Hello, world!", :routing_key => queue.name end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
amqp-0.8.0.rc2 | examples/hello_world.rb |
amqp-0.8.0.rc1 | examples/hello_world.rb |
amqp-0.8.0.pre.beta1 | examples/hello_world.rb |
amqp-0.8.0.beta1 | examples/hello_world.rb |