This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 01dcbe44d02 (chores) camel-jms: formatting fixes
01dcbe44d02 is described below
commit 01dcbe44d028b6b82cb1b12a08ab8335d81e8d80
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Jan 11 14:00:12 2024 +0100
(chores) camel-jms: formatting fixes
---
.../test/java/org/apache/camel/component/jms/JmsDeliveryDelayTest.java | 2 +-
.../java/org/apache/camel/component/jms/JmsTopicDurableSharedTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeliveryDelayTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeliveryDelayTest.java
index 175e2e8d909..132b5d7f08e 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeliveryDelayTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsDeliveryDelayTest.java
@@ -51,7 +51,7 @@ public class JmsDeliveryDelayTest extends
AbstractPersistentJMSTest {
routeWatch.restart();
template.sendBody("activemq:topic:JmsDeliveryDelayTest?deliveryDelay=1000",
"Hello World");
- if(!routeComplete.await(2000, TimeUnit.MILLISECONDS)) {
+ if (!routeComplete.await(2000, TimeUnit.MILLISECONDS)) {
fail("Message was not received from Artemis topic for too long");
}
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTopicDurableSharedTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTopicDurableSharedTest.java
index 4b634420229..a07e2673ce2 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTopicDurableSharedTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsTopicDurableSharedTest.java
@@ -29,7 +29,7 @@ import org.junit.jupiter.api.Test;
public class JmsTopicDurableSharedTest extends AbstractPersistentJMSTest {
private static final String TEST_DESTINATION_NAME =
"activemq:topic:in.only.topic.shared.durable.test";
-
+
@BeforeEach
void waitForArtemisToFinishCreatingConsumers() {
Awaitility.await().until(() ->
context.getClock().get(ContextEvents.START).elapsed() > 1000);