Class: ReliableMsg::MessageStore::Base
- Includes:
- DRbUndumped
- Defined in:
- lib/ap4r/message_store_ext.rb,
lib/ap4r/queue_manager_ext_debug.rb
Constant Summary collapse
- @@use_mysql_extention =
true
Instance Attribute Summary collapse
-
#cache ⇒ Object
readonly
Returns the value of attribute cache.
-
#mutex ⇒ Object
readonly
Returns the value of attribute mutex.
-
#queues ⇒ Object
readonly
Returns the value of attribute queues.
-
#topics ⇒ Object
readonly
Returns the value of attribute topics.
Instance Method Summary collapse
Instance Attribute Details
#cache ⇒ Object (readonly)
Returns the value of attribute cache.
46 47 48 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 46 def cache @cache end |
#mutex ⇒ Object (readonly)
Returns the value of attribute mutex.
46 47 48 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 46 def mutex @mutex end |
#queues ⇒ Object (readonly)
Returns the value of attribute queues.
46 47 48 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 46 def queues @queues end |
#topics ⇒ Object (readonly)
Returns the value of attribute topics.
46 47 48 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 46 def topics @topics end |
Instance Method Details
#activate ⇒ Object
50 51 52 53 54 55 56 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 50 def activate activate_original @mutex.extend DRbUndumped # @queues.extend DRbUndumped # @topics.extend DRbUndumped # @cache.extend DRbUndumped end |
#activate_original ⇒ Object
48 |
# File 'lib/ap4r/queue_manager_ext_debug.rb', line 48 alias activate_original activate |
#stale_queue(targets) ⇒ Object
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
# File 'lib/ap4r/message_store_ext.rb', line 12 def stale_queue targets queue_names = targets.split(/[\s;]/). select{|queue| !queue.empty? }. map{|queue| queue.strip! || queue } queue_and_created = @queues.select{|queue, | && (.size > 0) && queue_names.any?{|mq| if mq[-1] == '*'[0] queue[0..(mq.size-2)] == mq[0..-2] else queue == mq end } }.map{|queue, | [queue, [0][:created]] }.min {|q1, q2| q1[1] <=> q2[1] } queue_and_created ? queue_and_created[0] : nil end |