amqpを使ってRabbitMQのキューを操作する - Qiita

# -*- coding: utf-8 -*- require 'amqp' # RabbitMQに接続 AMQP.start(:host => "localhost", :vhost => "/production", :user => "user1", :pass => "pass") do |connection, open_ok| # channelを作成 channel = AMQP::Channel.new(connection) # queue1というキューを作成 # キューが無い場合は作成（既にある場合もエラーにはならない） queue = channel.queue("queue1") # exchangeを作成 exchange = channel.default_exchange # queue1にmessageを追加 exchange.publish("Hello,