Sha256: de1b26ea7ed4203cd11335e0281e0e90851dc456928cd4fe8e9002b9985cc9d8
Contents?: true
Size: 741 Bytes
Versions: 10
Compression:
Stored size: 741 Bytes
Contents
module Outboxer
VERSION: String
module Publisher
class Args
attr_reader message: untyped
attr_reader logger: Logger
def initialize: (untyped message, Logger logger) -> void
end
def self.publish: (?Integer poll, ?Proc[Integer, Integer] backoff) { (Args) -> untyped } -> void
def self.dequeue: ({ backoff: Proc[Integer, Integer] }) -> untyped
def self.published: ({ outboxer_message: untyped, backoff: Proc[Integer, Integer] }) -> void
def self.failed: ({ outboxer_message: untyped, exception: Exception, backoff: Proc[Integer, Integer] }) -> void
def self.retry_on_error: ({ backoff: Proc[Integer, Integer] }) { () -> untyped } -> untyped
def self.stop: () -> void
end
end
Version data entries
10 entries across 10 versions & 1 rubygems