lib/gorgon/originator_protocol.rb in gorgon-0.6.3 vs lib/gorgon/originator_protocol.rb in gorgon-0.6.4

@@ -43,16 +43,16 @@
     end
   end
 
   def cancel_job
     @file_queue.purge if @file_queue
-    @channel.fanout("gorgon.worker_managers").publish(cancel_message)
+    @channel.fanout("gorgon.worker_managers").publish(cancel_message) if @channel
     @logger.log "Cancel Message sent"
   end
 
   def disconnect
     cleanup_queues_and_exchange
-    @connection.disconnect
+    @connection.disconnect if @connection
   end
 
   private
 
   def open_queues