Class: ActionSubscriber::Base

Inherits:
Object
  • Object
show all
Extended by:
DSL, DefaultRouting, Subscribable
Defined in:
lib/action_subscriber/base.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods included from DefaultRouting

routes

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?, conditionally_add_filter!, 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