lib/modern_times/base/supervisor.rb in modern_times-0.3.1 vs lib/modern_times/base/supervisor.rb in modern_times-0.3.2

@@ -12,11 +12,10 @@
         @worker_klass   = worker_klass
         @name           = worker_options[:name] || worker_klass.default_name
         @worker_options = worker_options
         @workers        = []
         @worker_mutex   = Mutex.new
-        @failure_mutex  = Mutex.new
       end
 
       def worker_count
         @workers.size
       end
@@ -68,14 +67,10 @@
       def stopped?
         @stopped
       end
 
       def join
-        @workers.each { |worker| worker.thread.join }
-      end
-
-      def failure(worker, message)
-        
+        @workers.each { |worker| worker.join }
       end
 
       def mbean_name(domain)
         "#{domain}.Worker.#{@name}"
       end
\ No newline at end of file