This is an automated email from the ASF dual-hosted git repository.
aldettinger pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/main by this push:
new 2200e7de3b file: Add some extra logs to attempt catching info about
flakiness #3584
2200e7de3b is described below
commit 2200e7de3bbc2e603ceb54f5c52cee8a221abbd7
Author: aldettinger <[email protected]>
AuthorDate: Fri May 13 09:52:13 2022 +0200
file: Add some extra logs to attempt catching info about flakiness #3584
---
.../apache/camel/quarkus/component/file/it/FileResource.java | 10 ++++++++++
.../org/apache/camel/quarkus/component/file/it/FileRoutes.java | 2 ++
.../org/apache/camel/quarkus/component/file/it/FileTest.java | 3 +++
3 files changed, 15 insertions(+)
diff --git
a/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileResource.java
b/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileResource.java
index ce7586f0c2..87ccbc3299 100644
---
a/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileResource.java
+++
b/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileResource.java
@@ -99,18 +99,27 @@ public class FileResource {
@Path("/getFromMock/{mockId}")
@GET
public String getFromMock(@PathParam("mockId") String mockId) {
+ System.out.println("CAMEL-QUARKUS-3584 => FileResource.getFromMock(" +
mockId + ").thread.id => "
+ + Thread.currentThread().getId());
MockEndpoint mockEndpoint = context.getEndpoint("mock:" + mockId,
MockEndpoint.class);
+ System.out.println("CAMEL-QUARKUS-3584 => FileResource.getFromMock(" +
mockId + ").mockEndpoint => 0x"
+ + System.identityHashCode(mockEndpoint));
String result = mockEndpoint.getExchanges().stream().map(e ->
e.getIn().getBody(String.class))
.collect(Collectors.joining(SEPARATOR));
+ System.out.println("CAMEL-QUARKUS-3584 => FileResource.getFromMock(" +
mockId + ") returns => " + result);
+
return result;
}
@Path("/resetMock/{mockId}")
@GET
public void resetMock(@PathParam("mockId") String mockId) {
+ System.out.println("CAMEL-QUARKUS-3584 =>
FileResource.resetMock().thread.id => " + Thread.currentThread().getId());
MockEndpoint mockEndpoint = context.getEndpoint("mock:" + mockId,
MockEndpoint.class);
+ System.out.println(
+ "CAMEL-QUARKUS-3584 => FileResource.resetMock.mockEndpoint =>
0x" + System.identityHashCode(mockEndpoint));
mockEndpoint.reset();
}
@@ -121,6 +130,7 @@ public class FileResource {
public Response createFile(@PathParam("folder") String folder, byte[]
content, @QueryParam("charset") String charset,
@QueryParam("fileName") String fileName)
throws Exception {
+ System.out.println("CAMEL-QUARKUS-3584 =>
FileResource.createFile().thread.id => " + Thread.currentThread().getId());
StringBuilder url = new StringBuilder("file:target/" + folder +
"?initialDelay=10");
if (charset != null && !charset.equals("")) {
url.append("&charset=").append(charset);
diff --git
a/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileRoutes.java
b/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileRoutes.java
index 0986c97539..138f86b0e7 100644
---
a/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileRoutes.java
+++
b/integration-tests/file/src/main/java/org/apache/camel/quarkus/component/file/it/FileRoutes.java
@@ -62,10 +62,12 @@ public class FileRoutes extends RouteBuilder {
.to("mock:charsetIsoRead");
from("file://target/idempotent?idempotent=true&move=done/${file:name}&initialDelay=0&delay=10")
+ .log("CAMEL-QUARKUS-3584 =>
from(\"file://target/idempotent?idempotent=true&move=done/${file:name}&initialDelay=0&delay=10\")...
consumed message ${body}")
.convertBodyTo(String.class).to("mock:idempotent");
bindToRegistry("myFilter", new MyFileFilter<>());
from(("file://target/filter?initialDelay=0&delay=10&filter=#myFilter"))
+ .log("CAMEL-QUARKUS-3584 =>
from(\"file://target/filter?initialDelay=0&delay=10&filter=#myFilter\")...
consumed message ${body}")
.convertBodyTo(String.class).to("mock:filter");
from(("file://target/sortBy?initialDelay=0&delay=10&sortBy=reverse:file:name"))
diff --git
a/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java
b/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java
index 853660079e..f3e4b46552 100644
---
a/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java
+++
b/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java
@@ -112,6 +112,7 @@ class FileTest {
@Test
public void idempotent() throws IOException {
+ System.out.println("CAMEL-QUARKUS-3584 =>
FileTest.idempotent().thread.id => " + Thread.currentThread().getId());
// Create a new file
String fileName01 = createFile(FILE_CONTENT_01,
"/file/create/idempotent");
@@ -149,6 +150,7 @@ class FileTest {
@Test
public void filter() throws IOException {
+ System.out.println("CAMEL-QUARKUS-3584 => FileTest.filter().thread.id
=> " + Thread.currentThread().getId());
String fileName = createFile(FILE_CONTENT_01, "/file/create/filter",
null, "skip_" + UUID.randomUUID().toString());
createFile(FILE_CONTENT_02, "/file/create/filter");
@@ -164,6 +166,7 @@ class FileTest {
@Test
public void sortBy() throws IOException, InterruptedException {
+ System.out.println("CAMEL-QUARKUS-3584 => FileTest.sortBy().thread.id
=> " + Thread.currentThread().getId());
createFile(FILE_CONTENT_03, "/file/create/" + SORT_BY, null, "c_" +
UUID.randomUUID().toString());
createFile(FILE_CONTENT_01, "/file/create/" + SORT_BY, null, "a_" +
UUID.randomUUID().toString());
createFile(FILE_CONTENT_02, "/file/create/" + SORT_BY, null, "b_" +
UUID.randomUUID().toString());
