Module: Promiscuous::Subscriber::Upsert

Extended by:
ActiveSupport::Concern
Included in:
ActiveRecord
Defined in:
lib/promiscuous/subscriber/upsert.rb

Instance Method Summary collapse

Instance Method Details

#fetch ⇒ Object 



4
5
6
7
8
9
10
11
 
# File 'lib/promiscuous/subscriber/upsert.rb', line 4

def fetch
  begin
    super
  rescue self.class.missing_record_exception
    Promiscuous.warn "[receive] upserting #{payload}"
    fetch_new
  end
end