bin/jflow_worker in jflow-0.1.0 vs bin/jflow_worker in jflow-0.2.0

@@ -20,20 +20,21 @@
 validator = HashValidator.validate(configuration, configuration_validator)
 raise "configuration is invalid! #{validator.errors}" unless validator.valid?
 
 JFlow.configure do |c|
   c.load_paths = configuration["activities_path"]
+  c.swf_client = Aws::SWF::Client.new
 end
 
 JFlow.load_activities
 
 threads = []
 
 configuration["number_of_workers"].times do |i|
   threads << Thread.new do
     domain   = configuration["domain"]
     tasklist = configuration["tasklist"]
-    JFlow::ActivityWorker.new(domain, tasklist)
+    JFlow::Activity::Worker.new(domain, tasklist)
                          .start!
   end
 end
 
 threads.each { |thr| thr.join }