Class: Railbox::Models::TransactionalOutbox

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
lib/railbox/models/transactional_outbox.rb

Overview

Schema Information

Table name: transactional_outboxes

id :bigint not null, primary key action_type :string not null # Type of action/event (class_method/http) action_data :jsonb not null # Action data or payload ("MyService", process_method: "create"/"POST", url: "https://...") (default: {}) status :string not null # Processing status (e.g. in_progress, failed, completed) entity_type :string # Polymorphic type for associated entity entity_id :integer # Polymorphic ID for associated entity query :jsonb # Url query (JSON) body :jsonb # Main body/payload (default: {}) headers :jsonb # Headers (default: {}) meta :jsonb # Metadata or extra info (JSON) attempts :integer default(0) # Number of processing attempts retry_at :datetime # Next retry timestamp failure_reasons :jsonb, array # Array of failure reason objects created_at :datetime not null # Record creation timestamp updated_at :datetime not null # Last update timestamp

Indexes

index_transactional_outboxes_on_entity_type_and_entity_id (entity_type,entity_id)

Purpose:

- Queues reliable actions/events for external systems.
- Tracks delivery status and retry logic.
- Stores metadata and failure reasons for auditing/debugging.

Instance Method Summary collapse

Instance Method Details

#action_data ⇒ Object 



37
38
39
 
# File 'lib/railbox/models/transactional_outbox.rb', line 37

def action_data
  super&.deep_symbolize_keys || {}
end

#entity_group ⇒ Object 



49
50
51
 
# File 'lib/railbox/models/transactional_outbox.rb', line 49

def entity_group
  "#{entity_type}.#{entity_id}"
end

#group ⇒ Object 



45
46
47
 
# File 'lib/railbox/models/transactional_outbox.rb', line 45

def group
  action_data[:group]
end

#in_group? ⇒ Boolean

Returns:

  • (Boolean) 


41
42
43
 
# File 'lib/railbox/models/transactional_outbox.rb', line 41

def in_group?
  group.present? || entity_group.present?
end