Sha256: e2c440e09ab740fe3b73ed5b1b812d5b9a2cbbae883df8d7b13f5cf515a53e0e

Contents?: true

Size: 833 Bytes

Versions: 5

Compression:

Stored size: 833 Bytes

Contents

#
# testing ruote
#
# Thu Dec 10 14:08:30 JST 2009
#

require File.join(File.dirname(__FILE__), '..', 'test_helper.rb')

require 'ruote/parser/ruby_dsl'
require 'ruote/engine'
require 'ruote/worker'
require 'ruote/storage/hash_storage'
require 'ruote/part/hash_participant'


class UtWaitLoggerTest < Test::Unit::TestCase

  def test_wait_for_participant

    pdef = Ruote.process_definition :name => 'test' do
      sequence do
        #wait '1'
        alpha
      end
    end

    engine = Ruote::Engine.new(Ruote::Worker.new(Ruote::HashStorage.new))

    #engine.context.logger.noisy = true

    alpha = engine.register_participant :alpha, Ruote::HashParticipant.new

    engine.launch(pdef)
    msg = engine.wait_for(:alpha)

    assert_equal 1, alpha.size

    assert_not_nil msg
    assert_not_nil msg['workitem']
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
ruote-2.1.11 test/unit/ut_3_wait_logger.rb
ruote-2.1.10 test/unit/ut_3_wait_logger.rb
ruote-2.1.9 test/unit/ut_3_wait_logger.rb
ruote-2.1.8 test/unit/ut_3_wait_logger.rb
ruote-2.1.7 test/unit/ut_3_wait_logger.rb