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 collapse
- VERSION =
"0.0.6"
- CODENAME =
"Trickle"
Class Method Summary collapse
-
.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.
13 14 15 |
# 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
20 21 22 |
# File 'lib/firehose.rb', line 20 def self.reset! @amqp = nil end |