INTSCALA-41 - Small fixes - start() and stop()

spring-attic · Jun 11, 2012 · de6e18b · de6e18b
1 parent 96475b9
commit de6e18b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/spring-integration-dsl-scala-jdbc/src/test/scala/JdbcPollingChannelAdapterTests.scala b/spring-integration-dsl-scala-jdbc/src/test/scala/JdbcPollingChannelAdapterTests.scala
@@ -86,13 +86,13 @@ class JdbcPollingChannelAdapterTests {
           m: Message[_] => this.message = m
         }
 
-    inboundFlow.start()
+    inboundFlow start
 
     jdbcTemplate.update("insert into item (id, status) values(1,2)")
 
     Thread.sleep(200)
 
-    inboundFlow.stop()
+    inboundFlow stop
 
     assertNotNull(message)
     assertEquals(1, Utils.get(message, "ID"))
@@ -116,13 +116,13 @@ class JdbcPollingChannelAdapterTests {
 
     val outboundFlow = transform{p:String => p.toUpperCase()} --> jdbc.store(query, jdbcTemplate getDataSource)
 
-    inboundFlow.start()
+    inboundFlow start
 
     outboundFlow.send("")
 
     Thread.sleep(200)
 
-    inboundFlow.stop()
+    inboundFlow stop
 
     assertNotNull(message)
     assertEquals(3, Utils.get(message, "ID"))

diff --git a/spring-integration-dsl-scala-jdbc/src/test/scala/demo/DslUsageDemoTests.scala b/spring-integration-dsl-scala-jdbc/src/test/scala/demo/DslUsageDemoTests.scala
@@ -65,13 +65,13 @@ class DslUsageDemoTests {
           m: Message[_] => this.message = m
         }
 
-    inboundFlow.start()
+    inboundFlow start
 
     jdbcTemplate.update("insert into item (id, status) values(1,2)")
 
     Thread.sleep(200)
 
-    inboundFlow.stop()
+    inboundFlow stop
 
     assertNotNull(message)
 
@@ -89,13 +89,13 @@ class DslUsageDemoTests {
           m: Message[_] => this.message = m
         }
 
-    inboundFlow.start()
+    inboundFlow start
 
     jdbcTemplate.update("insert into item (id, status) values(1,2)")
 
     Thread.sleep(200)
 
-    inboundFlow.stop()
+    inboundFlow stop
 
     assertNotNull(message)
 
@@ -117,13 +117,13 @@ class DslUsageDemoTests {
 
     val outboundFlow = transform{p:String => p.toUpperCase()} --> jdbc.store(query, jdbcTemplate getDataSource)
 
-    inboundFlow.start()
+    inboundFlow start
 
     outboundFlow.send("")
 
     Thread.sleep(200)
 
-    inboundFlow.stop()
+    inboundFlow stop
 
     assertNotNull(message)