class Crabbit::ProducerOptions

• Crabbit::ProducerOptions
• Reference
• Object

Overview

Configures publisher batching, confirms, filtering, backpressure, and recovery.

Defined in:

Constructors

• .new(name : String | Nil = nil, batch_size : Int32 = 100, sub_entry_size : Int32 = 1, compression : Compression = Compression::None, max_unconfirmed : Int32 = 10000, batch_delay : Time::Span = 100.milliseconds, confirm_timeout : Time::Span = 30.seconds, enqueue_timeout : Time::Span | Nil = nil, retry_on_recovery : Bool = true, filter_value_extractor : Proc(Message, String | Nil) | Nil = nil, recovery_policy : RecoveryPolicy = RecoveryPolicy.new, on_state_change : Proc(ResourceEvent, Nil) | Nil = nil)

  Creates publisher options.

Instance Method Summary

• #batch_delay : Time::Span

  Returns how long the batch worker waits for more messages.

• #batch_size : Int32

  Returns the maximum number of logical messages collected per wire batch.

• #compression : Compression

  Returns the compression used for sub-entry batches.

• #confirm_timeout : Time::Span

  Returns the default publisher-confirmation timeout.

• #enqueue_timeout : Time::Span | Nil

  Returns the optional timeout for waiting on backpressure capacity.

• #filter_value_extractor : Proc(Message, String | Nil) | Nil

  Returns the optional server-side filter value extractor.

• #max_unconfirmed : Int32

  Returns the hard limit of publishes awaiting confirmation.

• #name : String | Nil

  Returns the optional publisher reference used for broker deduplication.

• #on_state_change : Proc(ResourceEvent, Nil) | Nil

  Returns the optional asynchronous lifecycle listener.

• #recovery_policy : RecoveryPolicy

  Returns the reconnect backoff policy.

• #retry_on_recovery : Bool

  Returns whether unresolved messages are republished after recovery.

• #sub_entry_size : Int32

  Returns the number of logical messages packed into each sub-entry.

Constructor Detail

Instance Method Detail