lib/amqp/queue.rb in amqp-0.8.0.rc3 vs lib/amqp/queue.rb in amqp-0.8.0.rc4
- old
+ new
@@ -3,11 +3,11 @@
require "amq/client/queue"
module AMQP
# h2. What are AMQP queues?
#
- # Queues store and forward messages to consumers. They similar to mailboxes in SMTP.
+ # Queues store and forward messages to consumers. They are similar to mailboxes in SMTP.
# Messages flow from producing applications to {Exchange exchanges} that route them
# to queues and finally queues deliver them to consumer applications (or consumer
# applications fetch messages as needed).
#
# Note that unlike some other messaging protocols/systems, messages are not delivered directly
@@ -40,38 +40,12 @@
# path segments are separated by a slash (/), although it may be almost any string, with some limitations (see below).
# Applications may pick queue names or ask broker to generate a name for them. To do so, pass *empty string* as queue name argument.
#
# Here is an example:
#
- # @example Declaring a server-named queue using AMQP::Queue constructor
- # AMQP.start("amqp://guest:guest@dev.rabbitmq.com:5672/") do |connection, open_ok|
- # AMQP::Channel.new do |channel, open_ok|
- # AMQP::Queue.new(channel, "", :auto_delete => true) do |queue, declare_ok|
- # puts "#{queue.name} is ready to go. AMQP method: #{declare_ok.inspect}"
- #
- # connection.close {
- # EM.stop { exit }
- # }
- # end
- # end
- # end
- #
# <script src="https://gist.github.com/939596.js?file=gistfile1.rb"></script>
#
# If you want to declare a queue with a particular name, for example, "images.resize", pass it to Queue class constructor:
- #
- # @example Declaring a server-named queue using AMQP::Queue constructor
- # AMQP.start("amqp://guest:guest@dev.rabbitmq.com:5672/") do |connection, open_ok|
- # AMQP::Channel.new do |channel, open_ok|
- # AMQP::Queue.new(channel, "images.resize", :auto_delete => true) do |queue, declare_ok|
- # puts "#{queue.name} is ready to go."
- #
- # connection.close {
- # EM.stop { exit }
- # }
- # end
- # end
- # end
#
# <script src="https://gist.github.com/939600.js?file=gistfile1.rb"></script>
#
# Queue names starting with 'amq.' are reserved for internal use by the broker. Attempts to declare queue with a name that violates this
# rule will result in AMQP::IncompatibleOptionsError to be thrown (when