0
@@ -8,6 +8,15 @@ module Simplified
0
 
0
   class Starling
0
 
0
+    def self.running?
0
+      config = YAML.load_file("#{RAILS_ROOT}/config/starling.yml")[RAILS_ENV]
0
+      if File.exist?(config['pid_file'])
0
+        Process.getpgid(File.read(config['pid_file']).to_i) rescue return false
0
+      else
0
+        return false
0
+      end
0
+    end
0
+
0
     def self.prepare(queue)
0
       self.feedback("Queue processor started for `#{queue}`.")
0
       start_processing(queue)

0
@@ -6,7 +6,7 @@ namespace :simplified_starling do
0
   desc "Start starling server"
0
   task :start do
0
     config = YAML.load_file("#{RAILS_ROOT}/config/starling.yml")[RAILS_ENV]
0
-    unless File.exist?(config['pid_file'])
0
+    unless Simplified::Starling.running?
0
       starling_binary = `which starling`.strip
0
       raise RuntimeError, "Cannot find starling" if starling_binary.blank?
0
       options = []