This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new bba7b2f Fixed test
bba7b2f is described below
commit bba7b2f4407e668cb75d32ea2e63e9727cbd8e2c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri May 31 07:29:56 2019 +0200
Fixed test
---
.../camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java | 8 ++++----
.../component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java | 6 +++---
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
index a267032..8ce404c 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
@@ -44,8 +44,8 @@ public class AsyncEndpointJmsTXMulticastTest extends
CamelSpringTestSupport {
assertMockEndpointsSatisfied();
- // we are asynchronous due to multicast so that we are NOT using same
threads during the routing
- assertFalse("Should not use same threads",
beforeThreadName.equalsIgnoreCase(afterThreadName));
+ // we are asynchronous due to multicast so we should ideally use same
thread during processing
+ assertTrue("Should use same threads",
beforeThreadName.equalsIgnoreCase(afterThreadName));
}
@Override
@@ -65,7 +65,7 @@ public class AsyncEndpointJmsTXMulticastTest extends
CamelSpringTestSupport {
assertTrue("Exchange should be transacted",
exchange.isTransacted());
}
})
- // if we use mutlicast then we cannot propagate
transactions across
+ // if we use mutlicast then we can propagate
transactions across
.multicast().to("direct:foo");
from("direct:foo")
@@ -73,7 +73,7 @@ public class AsyncEndpointJmsTXMulticastTest extends
CamelSpringTestSupport {
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
afterThreadName =
Thread.currentThread().getName();
- assertFalse("Exchange should NO longer be
transacted", exchange.isTransacted());
+ assertTrue("Exchange should be transacted",
exchange.isTransacted());
}
})
.to("log:after")
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
index dd7778f..02e76f0 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
@@ -44,8 +44,8 @@ public class AsyncEndpointJmsTXRecipientListTest extends
CamelSpringTestSupport
assertMockEndpointsSatisfied();
- // we are asynchronous due to recipientlist so that we are NOT using
same threads during the routing
- assertFalse("Should not use same threads",
beforeThreadName.equalsIgnoreCase(afterThreadName));
+ // we are asynchronous due to multicast so we should ideally use same
thread during processing
+ assertTrue("Should use same threads",
beforeThreadName.equalsIgnoreCase(afterThreadName));
}
@Override
@@ -72,7 +72,7 @@ public class AsyncEndpointJmsTXRecipientListTest extends
CamelSpringTestSupport
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
afterThreadName =
Thread.currentThread().getName();
- assertFalse("Exchange should NO longer be
transacted", exchange.isTransacted());
+ assertTrue("Exchange should be transacted",
exchange.isTransacted());
}
})
.to("log:after")
