标签：style   http   io   os   ar   strong   for   div   art   

http://rdoc.info/github/ruby-amqp/bunny/Bunny/Queue

Class: Bunny::Queue

Inherits:

Object show all

Defined in:

lib/bunny/queue.rb

Overview

Instance Attribute Summary (collapse)

• - (Bunny::Channel) channel readonly

  Channel this queue uses.

• - (String) name readonly

  Queue name.

• - (Hash) options readonly

  Options this queue was created with.

Instance Method Summary (collapse)

• - (Hash) arguments

  Additional optional arguments (typically used by RabbitMQ extensions and plugins).

• - (Boolean) auto_delete?

  True if this queue was declared as automatically deleted (deleted as soon as last consumer unbinds).

• - (Object) bind(exchange, opts = {})

  Binds queue to an exchange.

• - (Integer) consumer_count

  How many active consumers the queue has.

• - (Object) delete(opts = {})

  Deletes the queue.

• - (Boolean) durable?

  True if this queue was declared as durable (will survive broker restart).

• - (Boolean) exclusive?

  True if this queue was declared as exclusive (limited to just one consumer).

• - (Queue) initialize(channel_or_connection, name = AMQ::Protocol::EMPTY_STRING, opts = {}) constructor

  A new instance of Queue.

• - (Integer) message_count

  How many messages the queue has ready (e.g. not delivered but not unacknowledged).

• - (Array) pop(opts = {:manual_ack => false}, &block) (also: #get)

  Triple of delivery info, message properties and message content.

• - (Object) publish(payload, opts = {})

  Publishes a message to the queue via default exchange.

• - (Object) purge(opts = {})

  Purges a queue (removes all messages from it).

• - (Boolean) server_named?

  True if this queue was declared as server named.

• - (Hash) status

  A hash with information about the number of queue messages and consumers.

• - (Object) subscribe(opts = { :consumer_tag => @channel.generate_consumer_tag, :manual_ack => false, :exclusive => false, :block => false, :on_cancellation => nil }, &block)

  Adds a consumer to the queue (subscribes for message deliveries).

• - (Object) subscribe_with(consumer, opts = {:block => false})

  Adds a consumer object to the queue (subscribes for message deliveries).

• - (Object) unbind(exchange, opts = {})

  Unbinds queue from an exchange.

Instance Method Details

conn = Bunny.new
conn.start

ch   = conn.create_channel
q = ch.queue("test1")
x = ch.default_exchange
x.publish("Hello, everybody!", :routing_key => ‘test1‘)

delivery_info, properties, payload = q.pop

puts "This is the message: " + payload + "\n\n"
conn.close

permalink - (Object) unbind(exchange, opts = {})

bunny for rabbitmq

标签：style   http   io   os   ar   strong   for   div   art   

原文地址：http://www.cnblogs.com/qinyan20/p/3982033.html