Changeset 281
- Timestamp:
- 12/16/07 04:18:09 (8 months ago)
- Files:
-
- trunk/examples/workers/foo_worker.rb (modified) (1 diff)
- trunk/examples/workers/god_worker.rb (added)
- trunk/examples/workers/model_worker.rb (added)
- trunk/examples/workers/rss_worker.rb (added)
- trunk/examples/workers/server_worker.rb (added)
- trunk/examples/workers/xmpp_worker.rb (added)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/examples/workers/foo_worker.rb
r264 r281 3 3 # models. You also get logger and results method inside of this class 4 4 # by default. 5 6 class TimeClient 7 def receive_data(p_data) 8 worker.get_external_data(p_data) 9 end 10 11 def post_init 12 p "***************** : connection completed" 13 end 14 end 15 5 16 class FooWorker < BackgrounDRb::MetaWorker 6 17 set_worker_name :foo_worker 7 18 def create(args = nil) 8 19 #register_status("Running") 20 add_periodic_timer(10) { foobar } 21 external_connection = nil 22 connect("localhost",11009,TimeClient) { |conn| external_connection = conn } 23 end 24 25 def get_external_data(p_data) 26 register_status(p_data) 9 27 end 10 28 11 29 def foobar 12 logger.info("invoking foobar on#{Time.now}")30 register_status("Hello #{Time.now}") 13 31 end 14 32
