diff --git a/spring-integration-dsl-scala-jdbc/src/test/scala/JdbcPollingChannelAdapterTests.scala b/spring-integration-dsl-scala-jdbc/src/test/scala/JdbcPollingChannelAdapterTests.scala
index 582040f..049a886 100644
--- 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
index 4e4b3df..608f046 100644
--- 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)