Module: Promiscuous::Subscriber::Mongoid::Upsert

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

Instance Method Summary collapse

Instance Method Details

#fetch ⇒ Object 



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

def fetch
  begin
    super
  rescue Mongoid::Errors::DocumentNotFound
    Promiscuous::AMQP.warn "[receive] upserting #{payload}"
    klass.new.tap { |o| o.id = id }
  end
end