Module: RosettaQueue

Defined in:
lib/rosetta_queue/adapters/amqp.rb,
lib/rosetta_queue/base.rb,
lib/rosetta_queue/logger.rb,
lib/rosetta_queue/logger.rb,
lib/rosetta_queue/adapter.rb,
lib/rosetta_queue/filters.rb,
lib/rosetta_queue/consumer.rb,
lib/rosetta_queue/producer.rb,
lib/rosetta_queue/exceptions.rb,
lib/rosetta_queue/destinations.rb,
lib/rosetta_queue/adapters/base.rb,
lib/rosetta_queue/adapters/fake.rb,
lib/rosetta_queue/adapters/null.rb,
lib/rosetta_queue/adapters/stomp.rb,
lib/rosetta_queue/message_handler.rb,
lib/rosetta_queue/adapters/beanstalk.rb,
lib/rosetta_queue/spec_helpers/helpers.rb,
lib/rosetta_queue/consumer_managers/base.rb,
lib/rosetta_queue/consumer_managers/evented.rb,
lib/rosetta_queue/consumer_managers/threaded.rb,
lib/rosetta_queue/spec_helpers/publishing_matchers.rb

Overview

AMQP connections:

  • unlike stomp, we can share one connection across multiple channels

  • set host and authorization options on AMQP.connect

MQ create new channel for an AMQP connection options for queue and exchange objects include:

  • :durable => true

  • :ack => “client” ????

Defined Under Namespace

Modules: Gateway, Matchers, MessageHandler, SpecHelpers Classes: Adapter, AdapterException, Base, BaseManager, CallbackNotImplemented, Consumer, DestinationNotFound, Destinations, EventedManager, Filters, Logger, MissingLogger, Producer, RosettaQueueError, RosettaQueueVariableNotFound, StopProcessingException, ThreadedManager

Class Method Summary collapse

Class Method Details

.logger ⇒ Object

Raises:



10
11
12
13
 
# File 'lib/rosetta_queue/logger.rb', line 10

def self.logger
  return @logger if @logger
  raise MissingLogger, "No logger has been set for RosettaQueue.  Please define one with RosettaQueue.logger=."
end

.logger=(new_logger) ⇒ Object 



6
7
8
 
# File 'lib/rosetta_queue/logger.rb', line 6

def self.logger=(new_logger)
  @logger = new_logger
end