app/models/extface/driver.rb in extface-0.4.2a vs app/models/extface/driver.rb in extface-0.4.2

@@ -45,17 +45,17 @@
     end
     
     def push(buffer)
       if @job
         #retry if current device job is not @job (waiting on queue)
-        wait_on_queue = 2 #stop me writing endless things
-        if current_device_job = device.jobs(true).active.try(:first)
-          if current_device_job != @job
-            wait_on_queue = 20 #FIXME!
-            p "#### current_job is not first_on_queue"
-          end
-        end
+        wait_on_queue = 20 #stop me writing endless things
         begin
+          if current_device_job = device.jobs(true).active.try(:first)
+            if current_device_job != @job
+              #wait_on_queue = 20 #FIXME!
+              p "#### current_job is not first_on_queue"
+            end
+          end
           Timeout.timeout(Extface.device_timeout) do
             Extface.redis_block do |r|
               r.subscribe(@job.id) do |on| #blocking until delivered
                 on.subscribe do |channel, subscriptions|
                   @job.rpush buffer