Class: RailwayIpc::PublishedMessage

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
lib/railway_ipc/models/published_message.rb

Class Method Summary collapse

Class Method Details

.store_message(exchange_name, message) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/railway_ipc/models/published_message.rb', line 10

def self.store_message(exchange_name, message)
  encoded_message = RailwayIpc::Rabbitmq::Payload.encode(message)
  create!(
    uuid: message.uuid,
    message_type: message.class.to_s,
    user_uuid: message.user_uuid,
    correlation_id: message.correlation_id,
    encoded_message: encoded_message,
    status: 'sent',
    exchange: exchange_name
  )
end