class Emque::Consuming::Status

Public Instance Methods

to_h()
Alias for: to_hsh
to_hsh() click to toggle source
# File lib/emque/consuming/status.rb, line 6
def to_hsh
  {
    :app => config.app_name,
    :errors => {
      :count => app.error_tracker.count,
      :expire_after => app.error_tracker.expiration,
      :limit => app.error_tracker.limit
    },
    :workers => {}.tap { |worker_stats|
      app.manager.workers.each { |topic, workers|
        worker_stats[topic] = {
          :count => workers.size
        }
      }
    }
  }
end
Also aliased as: to_h