ft_32_journal.rb in ruote-0.9.19

- old
+ new
@@ -14,78 +14,78 @@
 require 'openwfe/expool/journal'
 
 
 
 class FlowTest32 < Test::Unit::TestCase
-    include FlowTestBase
+  include FlowTestBase
 
-    #def teardown
-    #end
+  #def teardown
+  #end
 
-    #def setup
-    #end
+  #def setup
+  #end
 
-    #
-    # TEST 0
+  #
+  # TEST 0
 
-    class TestDefinition0 < OpenWFE::ProcessDefinition
-        #concurrence do
-        sequence do
-            #set :variable => "//toto", :value => "nada"
-            participant :alpha
-            bravo
-        end
+  class TestDefinition0 < OpenWFE::ProcessDefinition
+    #concurrence do
+    sequence do
+      #set :variable => "//toto", :value => "nada"
+      participant :alpha
+      bravo
     end
+  end
 
-    def test_journal_0
+  def test_journal_0
 
-        @engine.application_context[:keep_journals] = true
+    @engine.application_context[:keep_journals] = true
 
-        @engine.init_service "journal", OpenWFE::Journal
+    @engine.init_service :s_journal, OpenWFE::Journal
 
-        @engine.register_participant(:alpha) do |wi|
-            @tracer << "alpha\n"
-        end
-        @engine.register_participant(:bravo) do |wi|
-            @tracer << "bravo\n"
-        end
+    @engine.register_participant(:alpha) do |wi|
+      @tracer << "alpha\n"
+    end
+    @engine.register_participant(:bravo) do |wi|
+      @tracer << "bravo\n"
+    end
 
-        #fei = dotest(TestDefinition0, "alpha\nbravo", 0.250)
-        fei = dotest(TestDefinition0, "alpha\nbravo")
+    result = dotest(TestDefinition0, "alpha\nbravo")
 
-        journal_service = @engine.application_context["journal"]
+    #journal_service = @engine.application_context[:s_journal]
+    journal_service = @engine.get_journal
 
-        fn = journal_service.donedir + "/" + fei.wfid + ".journal"
+    fn = journal_service.donedir + "/" + result[2].wfid + ".journal"
 
-        #puts journal_service.analyze fn
+    #puts journal_service.analyze fn
 
-        #sleep(10)
+    #sleep(10)
 
-        assert_equal @engine.get_expression_storage.size, 1
+    assert_equal @engine.get_expression_storage.size, 1
 
-        journal_service.replay fn, 18
-            #
-            # replay at offset 18 without "refiring"
-            #
-            # flow waits
+    journal_service.replay fn, 18
+      #
+      # replay at offset 18 without "refiring"
+      #
+      # flow waits
 
-        sleep 0.350
+    sleep 0.350
 
-        #puts
-        #puts @engine.get_expression_storage.to_s
-        #puts
+    #puts
+    #puts @engine.get_expression_storage.to_s
+    #puts
 
-        assert_equal @engine.get_expression_storage.size, 6
+    assert_equal @engine.get_expression_storage.size, 6
 
-        journal_service.replay fn, 18, true
-            #
-            # replay at offset 18 with "refiring"
-            #
-            # flow resumes
+    journal_service.replay fn, 18, true
+      #
+      # replay at offset 18 with "refiring"
+      #
+      # flow resumes
 
-        sleep 0.350
+    sleep 0.350
 
-        assert_equal @engine.get_expression_storage.size, 1
-    end
+    assert_equal @engine.get_expression_storage.size, 1
+  end
 
 end
 