lib/railway_ipc/models/published_message.rb in railway-ipc-0.1.7 vs lib/railway_ipc/models/published_message.rb in railway-ipc-1.0.0
- old
+ new
@@ -1,21 +1,23 @@
+# frozen_string_literal: true
+
module RailwayIpc
class PublishedMessage < ActiveRecord::Base
self.table_name = 'railway_ipc_published_messages'
- self.primary_key = "uuid"
+ self.primary_key = 'uuid'
validates :uuid, :status, presence: true
def self.store_message(exchange_name, message)
encoded_message = RailwayIpc::Rabbitmq::Payload.encode(message)
- self.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
+ 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
private