ditkrg/outboxable
4
0
Fork 0
mirror of https://github.com/ditkrg/outboxable.git synced 2026-01-22 13:56:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Runs publish inline after commit

Browse Source
This commit is contained in:
Brusk Awat 2023-04-25 12:39:20 +03:00
parent 6f598f40d4
commit 873f23ba59
Signed by: broosk1993
GPG Key ID: 5D20F7E02649F74E
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/templates/activerecrod_outbox.rb
View File

@ -4,7 +4,7 @@ class Outbox < ApplicationRecord
before_save :check_publishing
# Callbacks
before_create :set_last_attempted_at
after_save :publish, if: :allow_publish
after_commit :publish, if: :allow_publish?
# Enums
enum status: { pending: 0, processing: 1, published: 2, failed: 3 }
enum size: { single: 0, batch: 1 }
@ -20,8 +20,12 @@ class Outbox < ApplicationRecord
end
def publish
Outboxable::Worker.perform_async(id)
update(status: :processing, last_attempted_at: 1.minute.from_now, allow_publish: false)
# Run this in own thread
threaded = Thread.new do
Outboxable::Worker.perform_inline(id)
update(status: :processing, last_attempted_at: 1.minute.from_now, allow_publish: false)
end
threaded.join
end
def check_publishing