class ActionSubscriber::Base

Attributes

env[R]

Private Attributes

payload[R]

Private Attributes

raw_payload[R]

Private Attributes

Public Class Methods

inherited(klass) click to toggle source

Inherited callback, save a reference to our descendents

Calls superclass method
# File lib/action_subscriber/base.rb, line 31
def self.inherited(klass)
  super

  inherited_classes << klass
end
inherited_classes() click to toggle source

Storage for any classes that inherited from us

# File lib/action_subscriber/base.rb, line 39
def self.inherited_classes
  @_inherited_classes ||= []
end
Also aliased as: subscribers
new(env) click to toggle source

Constructor

# File lib/action_subscriber/base.rb, line 19
def initialize(env)
  @env = env
  @payload = env.payload
  @raw_payload = env.encoded_payload
end
subscribers()
Alias for: inherited_classes

Private Instance Methods

acknowledge() click to toggle source

Private Instance Methods

# File lib/action_subscriber/base.rb, line 55
def acknowledge
  env.acknowledge
end
redeliver(backoff_schedule = ::ActionSubscriber::MessageRetry::SCHEDULE) click to toggle source
# File lib/action_subscriber/base.rb, line 63
def redeliver(backoff_schedule = ::ActionSubscriber::MessageRetry::SCHEDULE)
  ::ActionSubscriber::MessageRetry::redeliver_message_with_backoff(env, backoff_schedule)
end
reject() click to toggle source
# File lib/action_subscriber/base.rb, line 59
def reject
  env.reject
end