Contents

class Outbox < ApplicationRecord
  attribute :allow_publish, :boolean, default: true

  # Callbacks
  after_commit :publish, if: :allow_publish?
  before_save :check_publishing

  # Enums
  enum status: { pending: 0, published: 1, failed: 2 }
  enum size: { single: 0, batch: 1 }

  # Validations
  validates :payload, presence: true
  validates :exchange, presence: true
  validates :routing_key, presence: true

  # Associations
  belongs_to :outboxable, polymorphic: true, optional: true

  def increment_attempt
    self.attempts = attempts + 1
    self.last_attempted_at = Time.zone.now
  end

  def publish
    Outboxable::Worker.perform_async(id)
  end

  def check_publishing
    self.allow_publish = false if published?
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
outboxable-0.1.2	lib/templates/outbox.rb
outboxable-0.1.1	lib/templates/outbox.rb
outboxable-0.1.0	lib/templates/outbox.rb