This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 5ee20cd Fix flaky test
5ee20cd is described below
commit 5ee20cd0f31b35424564c27418c764784005e842
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jan 14 07:09:28 2022 +0100
Fix flaky test
---
.../camel/impl/DefaultProducerTemplateAsyncTest.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
index b230697..f6023c6 100644
---
a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
@@ -43,8 +43,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
Exchange exchange = new DefaultExchange(context);
exchange.getIn().setBody("Hello");
- Future<Exchange> future = template.asyncSend("direct:start", exchange);
long start = System.currentTimeMillis();
+ Future<Exchange> future = template.asyncSend("direct:start", exchange);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -81,8 +81,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
@Test
public void testRequestAsyncBody() throws Exception {
- Future<Object> future = template.asyncRequestBody("direct:start",
"Hello");
long start = System.currentTimeMillis();
+ Future<Object> future = template.asyncRequestBody("direct:start",
"Hello");
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -98,8 +98,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
@Test
public void testRequestAsyncBodyType() throws Exception {
- Future<String> future = template.asyncRequestBody("direct:start",
"Hello", String.class);
long start = System.currentTimeMillis();
+ Future<String> future = template.asyncRequestBody("direct:start",
"Hello", String.class);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -120,8 +120,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
mock.expectedBodiesReceived("Hello World");
mock.expectedHeaderReceived("foo", 123);
- Future<Object> future =
template.asyncRequestBodyAndHeader("direct:start", "Hello", "foo", 123);
long start = System.currentTimeMillis();
+ Future<Object> future =
template.asyncRequestBodyAndHeader("direct:start", "Hello", "foo", 123);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -143,8 +143,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
mock.expectedBodiesReceived("Hello World");
mock.expectedHeaderReceived("foo", 123);
- Future<String> future =
template.asyncRequestBodyAndHeader("direct:start", "Hello", "foo", 123,
String.class);
long start = System.currentTimeMillis();
+ Future<String> future =
template.asyncRequestBodyAndHeader("direct:start", "Hello", "foo", 123,
String.class);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -171,8 +171,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
Map<String, Object> headers = new HashMap<>();
headers.put("foo", 123);
headers.put("bar", "cheese");
- Future<Object> future =
template.asyncRequestBodyAndHeaders("direct:start", "Hello", headers);
long start = System.currentTimeMillis();
+ Future<Object> future =
template.asyncRequestBodyAndHeaders("direct:start", "Hello", headers);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -198,8 +198,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
Map<String, Object> headers = new HashMap<>();
headers.put("foo", 123);
headers.put("bar", "cheese");
- Future<String> future =
template.asyncRequestBodyAndHeaders("direct:start", "Hello", headers,
String.class);
long start = System.currentTimeMillis();
+ Future<String> future =
template.asyncRequestBodyAndHeaders("direct:start", "Hello", headers,
String.class);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -221,8 +221,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
Exchange exchange = new DefaultExchange(context);
exchange.getIn().setBody("Hello");
- Future<Object> future = template.asyncRequestBody("direct:error",
exchange);
long start = System.currentTimeMillis();
+ Future<Object> future = template.asyncRequestBody("direct:error",
exchange);
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
@@ -241,8 +241,8 @@ public class DefaultProducerTemplateAsyncTest extends
ContextTestSupport {
@Test
public void testRequestAsyncBodyErrorWhenProcessing() throws Exception {
- Future<Object> future = template.asyncRequestBody("direct:error",
"Hello");
long start = System.currentTimeMillis();
+ Future<Object> future = template.asyncRequestBody("direct:error",
"Hello");
// you can do other stuff
String echo = template.requestBody("direct:echo", "Hi", String.class);
