Module: ActionPubsub::ActiveRecord::Events::Created

Extended by:
ActiveSupport::Concern
Defined in:
lib/action_pubsub/active_record/events/created.rb

Instance Method Summary collapse

Instance Method Details

#publish_created_event ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/action_pubsub/active_record/events/created.rb', line 14

def publish_created_event
  routing_key = [self.class.exchange_prefix, "created"].join("/")

  record_created_event = ::ActionPubsub::Event.new(
    :topic => routing_key,
    :record => self
  )

  ::ActiveRecord::Base.connection_pool.with_connection do
    ::ActionPubsub.publish_event(routing_key, record_created_event)
  end
end