Changeset 327 for trunk/examples/foo_controller.rb
- Timestamp:
- 08/10/08 03:34:20 (5 months ago)
- Files:
-
- trunk/examples/foo_controller.rb (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/examples/foo_controller.rb
r326 r327 9 9 10 10 def start_worker 11 MiddleMan.new_worker(:worker => :error_worker, : job_key => :hello_world,:data => "wow_man",:schedule => { :hello_world => { :trigger_args => "*/5 * * * * * *",:data => "hello_world" }})11 MiddleMan.new_worker(:worker => :error_worker, :worker_key => :hello_world,:data => "wow_man") 12 12 render :text => "worker starterd" 13 13 end 14 14 15 15 def stop_worker 16 MiddleMan. delete_worker(:worker => :error_worker, :job_key => :hello_world)16 MiddleMan.worker(:error_worker,:hello_world).delete 17 17 render :text => "worker deleted" 18 18 end 19 19 20 20 def invoke_worker_method 21 worker_response = MiddleMan. send_request(:worker => :world_worker, :worker_method => :hello_world)21 worker_response = MiddleMan.worker(:hello_worker).say_hello(:arg => data) 22 22 render :text => worker_response 23 23 end 24 24 25 25 def renew 26 MiddleMan. ask_work(:worker => :renewal_worker, :worker_method => :load_policies)26 MiddleMan.worker(:hello_worker).async_load_policy(:arg => current_user.id) 27 27 render :text => "method invoked" 28 28 end 29 29 30 def ask_status30 def query_all_workers 31 31 t_response = MiddleMan.query_all_workers 32 32 running_workers = t_response.map { |key,value| "#{key} = #{value}"}.join(',') 33 33 render :text => running_workers 34 end 35 36 def ask_result 37 t_result = MiddleMan.worker(:hello_worker).ask_result(cache_key) 34 38 end 35 39
