class Movie::Persistence::OutboxDispatcher

Overview

Claims a bounded lease, invokes the external publisher, then acknowledges success or releases the record for an at-least-once retry.

Defined in:

movie/persistence/runtime.cr

Constructors

.new(database : Movie::DatabaseExtension, owner : String, batch_size : Int32 = 100, lease : Time::Span = 30.seconds)

Instance Method Summary

#run_once(&publisher : StoredOutboxEntry -> ) : OutboxDispatchResult

Constructor Detail

def self.new(database : Movie::DatabaseExtension, owner : String, batch_size : Int32 = 100, lease : Time::Span = 30.seconds) #

[View source]

Instance Method Detail

def run_once(&publisher : StoredOutboxEntry -> ) : OutboxDispatchResult #

[View source]