Class: Pinky::EnergizerBunny::Subscription
- Inherits:
-
Object
- Object
- Pinky::EnergizerBunny::Subscription
- Defined in:
- lib/pinky/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.
6 7 8 9 10 |
# File 'lib/pinky/energizer_bunny/subscription.rb', line 6 def initialize queue, subscription_opts, logger, @queue, @subscription_opts, @logger, @handle_message = queue, subscription_opts, logger, @subscription_opts[:executor] = executor unless @subscription_opts[:executor] listen! end |
Instance Method Details
#close ⇒ Object
12 13 14 15 16 17 |
# File 'lib/pinky/energizer_bunny/subscription.rb', line 12 def close close_executor return if @subscription.nil? @subscription.shutdown! @subscription = nil end |