namespace :heartbeat do
  desc "Subscriber for AP monitoring"
  task subscribe: :environment do
    redis = Redis.connect(:host => APPLICATION[Rails.env]["redis"]["host"], :port => APPLICATION[Rails.env]["redis"]["port"])	
    redis.subscribe("bravo1") do |on|
      on.message do |channel, message|
        if $redis.llen("bravo") > 0
          a= HeartbeatWorker.perform_async(message)
          puts "Heartbeat worker:#{a}"
        end
     end
    end
  end
end