Class: EnergizerBunny::Subscription
- Inherits:
-
Object
- Object
- EnergizerBunny::Subscription
- Defined in:
- lib/energizer_bunny/subscription.rb
Instance Method Summary collapse
- #close ⇒ Object
-
#initialize(queue, subscription_opts, logger, handle_message) ⇒ Subscription
constructor
A new instance of Subscription.
Constructor Details
#initialize(queue, subscription_opts, logger, handle_message) ⇒ Subscription
Returns a new instance of Subscription.
5 6 7 8 9 10 |
# File 'lib/energizer_bunny/subscription.rb', line 5 def initialize queue, subscription_opts, logger, @queue, @subscription_opts, @logger, @handle_message = queue, subscription_opts.dup, logger, @reraise_errors = @subscription_opts.delete(:reraise_errors) @subscription_opts[:executor] = executor unless @subscription_opts[:executor] listen! end |
Instance Method Details
#close ⇒ Object
12 13 14 15 16 17 |
# File 'lib/energizer_bunny/subscription.rb', line 12 def close close_executor return if @subscription.nil? @subscription.shutdown! @subscription = nil end |