Method: ReliableMsg::QueueManager#initialize

Defined in:
lib/ap4r/queue_manager_ext.rb

#initialize(options = nil) ⇒ QueueManager

Hooks original initialize method to add lifecyle listeners. – TODO: Make dispatchers and carriers lifecyle listeners, 2006/09/01 shino



93
94
95
96
97
98
 
# File 'lib/ap4r/queue_manager_ext.rb', line 93

def initialize options = nil #:notnew:

  initialize_original options
  @global_lock ||= Mutex.new
  @lifecycle_listeners = []
  RetentionHistory.new(self, @logger, @config)
end