def amqp opts={}, &block
      opts = default_options.merge opts
      @evented_example = AMQPExample.new(opts, self, &block)
      @evented_example.run
    end
def amqp opts={}, &block
      opts = default_options.merge opts
      @evented_example = AMQPExample.new(opts, self, &block)
      @evented_example.run
    end
Yields to a given block inside EM.run and AMQP.start loops. This method takes
 any option that is accepted by EventMachine::connect. Options for AMQP.start include:
 * :user => String (default ‘guest’) - Username as defined by the AMQP server.
 * :pass => String (default ‘guest’) - Password as defined by the AMQP server.
 * :vhost => String (default ’/’)    - Virtual host as defined by the AMQP server.
 * :timeout => Numeric (default nil) - *Connection* timeout, measured in seconds.
 * :logging => Bool (default false) - Toggle the extremely verbose AMQP logging.

 In addition to EM and AMQP options, :spec_timeout option (in seconds) is used
 to force spec to timeout if something goes wrong and EM/AMQP loop hangs for some
 reason. SpecTimeoutExceededError is raised if it happens.