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
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