Class: ActionSubscriber::Base
- Inherits:
-
Object
- Object
- ActionSubscriber::Base
- Extended by:
- DSL, DefaultRouting, Subscribable
- Defined in:
- lib/action_subscriber/base.rb
Class Method Summary collapse
-
.inherited(klass) ⇒ Object
Inherited callback, save a reference to our descendents.
-
.inherited_classes ⇒ Object
(also: subscribers)
Storage for any classes that inherited from us.
Instance Method Summary collapse
-
#initialize(env) ⇒ Base
constructor
Constructor.
Methods included from DefaultRouting
Methods included from DSL
_run_action_at_least_once_with_filters, _run_action_at_most_once_with_filters, _run_action_with_filters, acknowledge_messages?, around_filter, around_filters, at_least_once!, at_least_once?, at_most_once!, at_most_once?, exchange_names, manual_acknowledgement!, manual_acknowledgement?, no_acknowledgement!, queue_for, queue_names, remote_application_name, routing_key_for, routing_key_names, run_action_with_filters
Methods included from Subscribable
allow_low_priority_methods?, filter_low_priority_methods, generate_queue_name, generate_routing_key_name, local_application_name, queue_name_for_method, resource_name, routing_key_name_for_method, subscribable_methods
Constructor Details
#initialize(env) ⇒ Base
Constructor
19 20 21 22 23 |
# File 'lib/action_subscriber/base.rb', line 19 def initialize(env) @env = env @payload = env.payload @raw_payload = env.encoded_payload end |
Class Method Details
.inherited(klass) ⇒ Object
Inherited callback, save a reference to our descendents
31 32 33 34 35 |
# File 'lib/action_subscriber/base.rb', line 31 def self.inherited(klass) super inherited_classes << klass end |
.inherited_classes ⇒ Object Also known as: subscribers
Storage for any classes that inherited from us
39 40 41 |
# File 'lib/action_subscriber/base.rb', line 39 def self.inherited_classes @_inherited_classes ||= [] end |