Adds initial 10 seconds as last_attempted_at so that it is not picked again by polling publisher

This commit is contained in:
Brusk Awat 2023-04-06 17:17:28 +03:00
parent 02bd4dcc00
commit cf5f49691f
Signed by: broosk1993
GPG Key ID: 5D20F7E02649F74E

View File

@ -10,15 +10,13 @@ class Outbox < ApplicationRecord
enum size: { single: 0, batch: 1 } enum size: { single: 0, batch: 1 }
# Validations # Validations
validates :payload, presence: true validates :payload, :exchange, :routing_key, presence: true
validates :exchange, presence: true
validates :routing_key, presence: true
# Associations # Associations
belongs_to :outboxable, polymorphic: true, optional: true belongs_to :outboxable, polymorphic: true, optional: true
def set_last_attempted_at def set_last_attempted_at
self.last_attempted_at = Time.zone.now self.last_attempted_at = 10.seconds.from_now
end end
def publish def publish