Changeset 327 for trunk/examples

Timestamp:

08/10/08 03:34:20 (5 months ago)

Author:

gethema..@gmail.com

Message:

sync code with git

Files:

• trunk/examples/foo_controller.rb (modified) (1 diff)
• trunk/examples/workers/foo_worker.rb (modified) (1 diff)
• trunk/examples/workers/rss_worker.rb (modified) (1 diff)

trunk/examples/foo_controller.rb

@@ -9 +9 @@
-
-  def start_worker
-job_key => :hello_world,:data => "wow_man",:schedule => { :hello_world => { :trigger_args => "*/5 * * * * * *",:data => "hello_world" }}
+worker_key => :hello_world,:data => "wow_man"
-    render :text => "worker starterd"
-  end
-
-  def stop_worker
-delete_worker(:worker => :error_worker, :job_key => :hello_world)
+worker(:error_worker,:hello_world).delete
-    render :text => "worker deleted"
-  end
-
-  def invoke_worker_method
-send_request(:worker => :world_worker, :worker_method => :hello_world
+worker(:hello_worker).say_hello(:arg => data
-    render :text => worker_response
-  end
-
-  def renew
-ask_work(:worker => :renewal_worker, :worker_method => :load_policies
+worker(:hello_worker).async_load_policy(:arg => current_user.id
-    render :text => "method invoked"
-  end
-
-ask_statu
+query_all_worker
-    t_response = MiddleMan.query_all_workers
-    running_workers = t_response.map { |key,value| "#{key} = #{value}"}.join(',')
-    render :text => running_workers
+  end
+
+  def ask_result
+    t_result = MiddleMan.worker(:hello_worker).ask_result(cache_key)
-  end
-

trunk/examples/workers/foo_worker.rb

@@ -24 +24 @@
-
-  def get_external_data(p_data)
-register_status(p_data)
+cache[some_key] = p_data
-  end
-
-  def foobar
-register_status("Hello #{Time.now}")
+cache[some_key] = "Time is now : #{Time.now}"
-  end
-

trunk/examples/workers/rss_worker.rb

@@ -10 +10 @@
-  def fetch_url(url)
-    puts "fetching url #{url}"
-url) do |url|
-    begin
-
-      File.open("#{RAILS_ROOT}/log/pages.txt","w") do |fl|
-      fl.puts(data)
-  end
-rescue
-logger.info "Error downloading page"
+:scrap_things,url)
+end
+
+def scrap_things url
+begin
+data = Net::HTTP.get(url,"/")
+File.open("#{RAILS_ROOT}/log/pages.txt","w") do |fl|
+fl.puts(data)
-      end
+    rescue
+      logger.info "Error downloading page"
-    end
-  end