Module: Firehose

Defined in:

lib/firehose.rb,
lib/firehose/cli.rb,
lib/firehose/rack.rb,
lib/firehose/thin.rb,
lib/firehose/version.rb,
lib/firehose/publisher.rb,
lib/firehose/subscription.rb,
lib/firehose/http_publisher.rb

Defined Under Namespace

Modules: Rack, Thin Classes: CLI, HttpPublisher, Publisher, Subscription

Constant Summary

VERSION =

"0.0.7"

CODENAME =

"Trickle"

Class Method Summary

• .amqp ⇒ Object

  TODO move this into a configuration or session class.

• .reset! ⇒ Object

  TODO figure out a better way to memoize AMQP connection for production runtimes, and make it resetable for testing environment.

Class Method Details

.amqp ⇒ Object

TODO move this into a configuration or session class. Hang on to AMQP configuration settings.

# File 'lib/firehose.rb', line 13

def self.amqp
  @amqp ||= Struct.new(:connection).new(AMQP.connect)
end

.reset! ⇒ Object

TODO figure out a better way to memoize AMQP connection for production runtimes, and make it resetable for testing environment. Some sort of Firehose::Session object is probably in order

# File 'lib/firehose.rb', line 20

def self.reset!
  @amqp = nil
end