|
Revision 327, 1.1 kB
(checked in by gethema..@gmail.com, 3 weeks ago)
|
sync code with git
|
| Line | |
|---|
| 1 |
class FooController < ApplicationController |
|---|
| 2 |
layout :choose_layout |
|---|
| 3 |
def index |
|---|
| 4 |
end |
|---|
| 5 |
|
|---|
| 6 |
def mobile_action |
|---|
| 7 |
#render :layout => "mobile" |
|---|
| 8 |
end |
|---|
| 9 |
|
|---|
| 10 |
def start_worker |
|---|
| 11 |
MiddleMan.new_worker(:worker => :error_worker, :worker_key => :hello_world,:data => "wow_man") |
|---|
| 12 |
render :text => "worker starterd" |
|---|
| 13 |
end |
|---|
| 14 |
|
|---|
| 15 |
def stop_worker |
|---|
| 16 |
MiddleMan.worker(:error_worker,:hello_world).delete |
|---|
| 17 |
render :text => "worker deleted" |
|---|
| 18 |
end |
|---|
| 19 |
|
|---|
| 20 |
def invoke_worker_method |
|---|
| 21 |
worker_response = MiddleMan.worker(:hello_worker).say_hello(:arg => data) |
|---|
| 22 |
render :text => worker_response |
|---|
| 23 |
end |
|---|
| 24 |
|
|---|
| 25 |
def renew |
|---|
| 26 |
MiddleMan.worker(:hello_worker).async_load_policy(:arg => current_user.id) |
|---|
| 27 |
render :text => "method invoked" |
|---|
| 28 |
end |
|---|
| 29 |
|
|---|
| 30 |
def query_all_workers |
|---|
| 31 |
t_response = MiddleMan.query_all_workers |
|---|
| 32 |
running_workers = t_response.map { |key,value| "#{key} = #{value}"}.join(',') |
|---|
| 33 |
render :text => running_workers |
|---|
| 34 |
end |
|---|
| 35 |
|
|---|
| 36 |
def ask_result |
|---|
| 37 |
t_result = MiddleMan.worker(:hello_worker).ask_result(cache_key) |
|---|
| 38 |
end |
|---|
| 39 |
|
|---|
| 40 |
private |
|---|
| 41 |
def choose_layout |
|---|
| 42 |
if action_name == 'mobile_action' |
|---|
| 43 |
"mobile" |
|---|
| 44 |
else |
|---|
| 45 |
"foo" |
|---|
| 46 |
end |
|---|
| 47 |
end |
|---|
| 48 |
end |
|---|