lib/rflow/shard.rb in rflow-1.0.1 vs lib/rflow/shard.rb in rflow-1.1.0

@@ -33,25 +33,25 @@
             RFlow.logger.error "Error in worker, shutting down: #{e.class.name}: #{e.message}, because: #{e.backtrace.inspect}"
             exit! 1
           end
         end
 
-        RFlow.logger.info "Shutting down worker after EM stopped"
+        RFlow.logger.info 'Shutting down worker after EM stopped'
       end
 
       def configure_components!
-        RFlow.logger.debug "Configuring components"
+        RFlow.logger.debug 'Configuring components'
         @components.zip(shard.config.components.map(&:options)).each do |(component, config)|
           RFlow.logger.debug "Configuring component '#{component.name}' (#{component.uuid})"
           component.configure! config
         end
       end
 
       # Connect all inputs before all outputs, so connection types that require a 'server'
       # to be established before a 'client' can connect can get themselves ready.
       def connect_components!
-        RFlow.logger.debug "Connecting components"
+        RFlow.logger.debug 'Connecting components'
         @components.each do |component|
           RFlow.logger.debug "Connecting inputs for component '#{component.name}' (#{component.uuid})"
           component.connect_inputs!
         end
         @components.each do |component|
@@ -59,19 +59,19 @@
           component.connect_outputs!
         end
       end
 
       def run_components!
-        RFlow.logger.debug "Running components"
+        RFlow.logger.debug 'Running components'
         @components.each do |component|
           RFlow.logger.debug "Running component '#{component.name}' (#{component.uuid})"
           component.run!
         end
       end
 
       def shutdown!(signal)
-        RFlow.logger.debug "Shutting down components"
+        RFlow.logger.debug 'Shutting down components'
         @components.each do |component|
           RFlow.logger.debug "Shutting down component '#{component.name}' (#{component.uuid})"
           component.shutdown!
         end
         EM.stop_event_loop
@@ -91,10 +91,10 @@
 
     def run!
       RFlow.logger.debug "Running shard #{name} with #{count} workers"
       workers.each(&:spawn!)
 
-      RFlow.logger.debug "#{count} workers started for #{name}: #{workers.map { |w| "#{w.name} (#{w.pid})" }.join(", ")}"
+      RFlow.logger.debug "#{count} workers started for #{name}: #{workers.map { |w| "#{w.name} (#{w.pid})" }.join(', ')}"
       workers
     end
   end
 end