Module: Pgbus::QueueFactory

Defined in:
lib/pgbus/queue_factory.rb

Overview

Dispatches queue operations based on queue type (standard vs priority). Replaces conditional ‘priority_enabled?` checks scattered through Client with a single strategy object selected at initialization.

Inspired by LavinMQ’s QueueFactory which dispatches queue creation by type: standard, durable, priority, stream, delayed.

Defined Under Namespace

Classes: PriorityStrategy, StandardStrategy

Class Method Summary collapse

Class Method Details

.for(config) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/pgbus/queue_factory.rb', line 11

def self.for(config)
  if config.priority_levels && config.priority_levels > 1
    PriorityStrategy.new(config)
  else
    StandardStrategy.new(config)
  end
end