Contents

module Bunnish::Core
  module Subscribe
    def self.output_subscribe_log(streams, queue, count, log_label)
      message_count = '?'
      consumer_count = '?'
      begin
        message_count = queue.status[:message_count]
        consumer_count = queue.status[:consumer_count]
      rescue Exception=>e
      end
    
      message = "#{log_label} subscribed #{count} messages from #{queue.name}(#{message_count} messages, #{consumer_count} consumers)"
      Bunnish::Core::Common.output_log(streams, "INFO", message)
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
bunnish-0.1.3	lib/bunnish/core/subscribe.rb
bunnish-0.1.2	lib/bunnish/core/subscribe.rb
bunnish-0.1.1	lib/bunnish/core/subscribe.rb
bunnish-0.1.0	lib/bunnish/core/subscribe.rb
bunnish-0.0.9	lib/bunnish/core/subscribe.rb
bunnish-0.0.8	lib/bunnish/core/subscribe.rb
bunnish-0.0.7	lib/bunnish/core/subscribe.rb
bunnish-0.0.6	lib/bunnish/core/subscribe.rb
bunnish-0.0.5	lib/bunnish/core/subscribe.rb
bunnish-0.0.4	lib/bunnish/core/subscribe.rb