1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

require 'scrubyt'

class FooWorker < BackgrounDRb::MetaWorker
  set_worker_name :foo_worker
  #  reload_on_schedule true
  pool_size(10)

  def create(args = nil)
    puts "started"
    cache[:start_message] = "Running"
#     @proxy_connection = nil
#     connect("localhost",11001,ProxyConnection) { |conn| @proxy_connection = conn }
  end

  def barbar(args = nil)
    logger.info "running bar bar #{Time.now} #{args}"
  end

  def who arg
    puts "running method who with #{arg}"
    google_data = Scrubyt::Extractor.define do
      fetch 'http://www.google.com/ncr'
      fill_textfield 'q', arg
      submit
      #Construct the wrapper
      link "Ruby Programming Language" do
        url "href", :type => :attribute
      end
      next_page "Next", :limit => 2
    end

    puts google_data.to_xml
  end

  def baz args
    puts "running baz with #{args}"
    return "hemant : #{args}"
  end

  def some_job count
    sleep 0.5
  end

  def stress_test args = nil
    logger.info "running stress test with #{args} #{Time.now}"
  end

  def queue_length args = nil
    return thread_pool.work_queue.length
  end

  def make_request data
    result = MiddleMan.worker(:hello_worker).make_request(:some_key,data)
    return result
  end
end