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