lib/asynchronic.rb in asynchronic-2.0.1 vs lib/asynchronic.rb in asynchronic-3.0.0

@@ -1,9 +1,10 @@
 require 'forwardable'
 require 'securerandom'
 require 'ost'
 require 'redic'
+require 'broadcaster'
 require 'class_config'
 require 'transparent_proxy'
 require 'logger'
 require 'multi_require'
 require 'timeout'
@@ -16,18 +17,19 @@
   extend ClassConfig
 
   attr_config :default_queue, :asynchronic
   attr_config :queue_engine, QueueEngine::InMemory.new
   attr_config :data_store, DataStore::InMemory.new
+  attr_config :notifier, Notifier::InMemory.new
   attr_config :logger, Logger.new($stdout)
   attr_config :retry_timeout, 30
   attr_config :garbage_collector_timeout, 30
   attr_config :redis_data_store_sync_timeout, 0.01
   attr_config :keep_alive_timeout, 0.1
   attr_config :connection_name, "HOST=#{Socket.gethostname},PID=#{::Process.pid}"
 
   def self.environment
-    Environment.new queue_engine, data_store
+    Environment.new queue_engine, data_store, notifier
   end
 
   def self.[](pid)
     environment.load_process pid
   end
\ No newline at end of file