Sha256: c4a4b18bca2b417c04c8585dbaba8e204aa266b2f86e8502b337c538077f9cc8

Contents?: true

Size: 695 Bytes

Versions: 2

Compression:

Stored size: 695 Bytes

Contents

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

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

require 'ruote'


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::StorageParticipant

    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

2 entries across 2 versions & 2 rubygems

Version Path
ruote-maestrodev-2.2.1 test/unit/ut_3_wait_logger.rb
ruote-2.2.0 test/unit/ut_3_wait_logger.rb