[camel] branch polish updated: Polish

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch polish
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/polish by this push:
     new abe97fea1f1 Polish
abe97fea1f1 is described below

commit abe97fea1f14392300ba2a08197b48f86fb1e5a5
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Jul 25 12:02:51 2023 +0200

    Polish
---
 .../quartz/SpringScheduledRoutePolicyTest.java           | 16 ++++------------
 1 file changed, 4 insertions(+), 12 deletions(-)

diff --git 
a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java
 
b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java
index 1f415bb60ed..40a50180a4e 100644
--- 
a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java
+++ 
b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/SpringScheduledRoutePolicyTest.java
@@ -56,9 +56,7 @@ public abstract class SpringScheduledRoutePolicyTest {
 
         context.getRouteController().stopRoute("testRoute", 1000, 
TimeUnit.MILLISECONDS);
 
-        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> {
-            assertSame(ServiceStatus.Started, 
context.getRouteController().getRouteStatus("testRoute"));
-        });
+        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> 
assertSame(ServiceStatus.Started, 
context.getRouteController().getRouteStatus("testRoute")));
 
         context.createProducerTemplate().sendBody("direct:start?timeout=1000", 
"Ready or not, Here, I come");
 
@@ -71,9 +69,7 @@ public abstract class SpringScheduledRoutePolicyTest {
 
         CamelContext context = startRouteWithPolicy("stopPolicy");
 
-        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> {
-            assertSame(ServiceStatus.Stopped, 
context.getRouteController().getRouteStatus("testRoute"));
-        });
+        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> 
assertSame(ServiceStatus.Stopped, 
context.getRouteController().getRouteStatus("testRoute")));
 
         assertThrows(CamelExecutionException.class,
                 () -> 
context.createProducerTemplate().sendBody("direct:start?timeout=1000", "Ready 
or not, Here, I come"));
@@ -87,9 +83,7 @@ public abstract class SpringScheduledRoutePolicyTest {
         CamelContext context = startRouteWithPolicy("suspendPolicy");
 
         // wait for route to suspend
-        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> {
-            
assertTrue(ServiceHelper.isSuspended(context.getRoute("testRoute").getConsumer()));
-        });
+        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> 
assertTrue(ServiceHelper.isSuspended(context.getRoute("testRoute").getConsumer())));
 
         assertThrows(CamelExecutionException.class,
                 () -> 
context.createProducerTemplate().sendBody("direct:start?timeout=1000", "Ready 
or not, Here, I come"));
@@ -107,9 +101,7 @@ public abstract class SpringScheduledRoutePolicyTest {
 
         
ServiceHelper.suspendService(context.getRoute("testRoute").getConsumer());
 
-        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> {
-            
assertTrue(ServiceHelper.isStarted(context.getRoute("testRoute").getConsumer()));
-        });
+        Awaitility.await().atMost(5, TimeUnit.SECONDS).untilAsserted(() -> 
assertTrue(ServiceHelper.isStarted(context.getRoute("testRoute").getConsumer())));
 
         context.createProducerTemplate().sendBody("direct:start?timeout=1000", 
"Ready or not, Here, I come");