Producing AMQP messages from Ruby On Rails applications - Brian Ploetz

Producing AMQP messages from Ruby On Rails applications

module Amqp # Helper methods for connecting to AMQP brokers in Rails apps. module Rails extend Configurable @connection_failure_handler = Proc.new do |settings| ::Rails.logger.error "Could not connect to AMQP broker! (settings: #{settings.inspect})" ::Rails.logger.error "Waiting 5 seconds to attempt to connect..." EventMachine.add_timer(5) do ::Rails.logger.error "Trying to connect to AMQP broker..." connect(settings) end end # Starts the EventMachine reactor (if necessary) and connects to the AMQP broker. # This class will handle connection failures and automatically attempt to re-connect # when the connection is lost after first being established. # # Assumes the file config/amqp.yml exists under Rails.root. # # Note that this class does NOT handle authentication failures with the broker. # Authentication failures will cause an uncaught exception and the app will not sta...

Full article: http://blog.brianploetz.com/post/36886084370/producing-am...