You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2020/11/13 08:20:48 UTC
[camel-quarkus] 03/05: nats: enabled connections fine grained
tracing to capture more information on next occurence of issue #1978
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 7eed674ae2cca58f1f4080d9710b6ae6ece5843e
Author: aldettinger <al...@gmail.com>
AuthorDate: Tue Nov 10 11:03:54 2020 +0100
nats: enabled connections fine grained tracing to capture more information on next occurence of issue #1978
---
.../camel/quarkus/component/nats/it/NatsRoutes.java | 17 +++++++++--------
.../camel/quarkus/component/nats/it/NatsTest.java | 15 ++++++++-------
2 files changed, 17 insertions(+), 15 deletions(-)
diff --git a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java
index 592c918..e830ab2 100644
--- a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java
+++ b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java
@@ -34,19 +34,20 @@ public class NatsRoutes extends RouteBuilder {
@Override
public void configure() {
- from("natsBasicAuth:test").routeId("basic-auth").bean(natsResource, "storeMessage");
- from("natsNoAuth:test").routeId("no-auth").bean(natsResource, "storeMessage");
- from("natsTokenAuth:test").routeId("token-auth").bean(natsResource, "storeMessage");
- from("natsTlsAuth:test?sslContextParameters=#ssl&secure=true").routeId("tls-auth").bean(natsResource, "storeMessage");
+ from("natsBasicAuth:test?traceConnection=true").routeId("basic-auth").bean(natsResource, "storeMessage");
+ from("natsNoAuth:test?traceConnection=true").routeId("no-auth").bean(natsResource, "storeMessage");
+ from("natsTokenAuth:test?traceConnection=true").routeId("token-auth").bean(natsResource, "storeMessage");
+ from("natsTlsAuth:test?sslContextParameters=#ssl&secure=true&traceConnection=true").routeId("tls-auth")
+ .bean(natsResource, "storeMessage");
- from("natsNoAuth:max?maxMessages=2").routeId("2-msg-max").bean(natsResource, "storeMessage");
+ from("natsNoAuth:max?maxMessages=2&traceConnection=true").routeId("2-msg-max").bean(natsResource, "storeMessage");
- String maxMsgUriPattern = "natsNoAuth:qmax?maxMessages=%s&queueName=q";
+ String maxMsgUriPattern = "natsNoAuth:qmax?maxMessages=%s&queueName=q&traceConnection=true";
fromF(maxMsgUriPattern, 3).routeId("3-qmsg-max").bean(natsResource, "storeMessage");
fromF(maxMsgUriPattern, 8).routeId("8-qmsg-max").bean(natsResource, "storeMessage");
- from("natsNoAuth:request-reply").setBody().simple("${body} => Reply");
- from("natsNoAuth:reply").routeId("reply").bean(natsResource, "storeMessage");
+ from("natsNoAuth:request-reply?traceConnection=true").setBody().simple("${body} => Reply");
+ from("natsNoAuth:reply?traceConnection=true").routeId("reply").bean(natsResource, "storeMessage");
}
@Named("ssl")
diff --git a/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTest.java b/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTest.java
index 177848f..1c9d57d 100644
--- a/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTest.java
+++ b/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTest.java
@@ -33,7 +33,7 @@ class NatsTest {
@Test
void basicAuthProduceConsumeRoundTripShouldSucceed() {
- Header header = new Header("sendToEndpointUri", "natsBasicAuth:test");
+ Header header = new Header("sendToEndpointUri", "natsBasicAuth:test?traceConnection=true");
given().when().header(header).body("basic-auth-msg").post("/nats/send").then().statusCode(204);
await().atMost(10L, TimeUnit.SECONDS).until(() -> {
@@ -47,7 +47,7 @@ class NatsTest {
@Test
void noAuthProduceConsumeRoundTripShouldSucceed() {
- Header header = new Header("sendToEndpointUri", "natsNoAuth:test");
+ Header header = new Header("sendToEndpointUri", "natsNoAuth:test?traceConnection=true");
given().when().header(header).body("no-auth-msg").post("/nats/send").then().statusCode(204);
await().atMost(10L, TimeUnit.SECONDS).until(() -> {
@@ -61,7 +61,8 @@ class NatsTest {
@Test
void tlsAuthProduceConsumeRoundTripShouldSucceed() {
- Header header = new Header("sendToEndpointUri", "natsTlsAuth:test?sslContextParameters=#ssl&secure=true");
+ Header header = new Header("sendToEndpointUri",
+ "natsTlsAuth:test?sslContextParameters=#ssl&secure=true&traceConnection=true");
given().when().header(header).body("tls-auth-msg").post("/nats/send").then().statusCode(204);
await().atMost(10L, TimeUnit.SECONDS).until(() -> {
@@ -75,7 +76,7 @@ class NatsTest {
@Test
void tokenAuthProduceConsumeRoundTripShouldSucceed() {
- Header header = new Header("sendToEndpointUri", "natsTokenAuth:test");
+ Header header = new Header("sendToEndpointUri", "natsTokenAuth:test?traceConnection=true");
given().when().header(header).body("token-auth-msg").post("/nats/send").then().statusCode(204);
await().atMost(10L, TimeUnit.SECONDS).until(() -> {
@@ -89,7 +90,7 @@ class NatsTest {
@Test
void consumeMaxMessagesShouldRetainFirstTwoMessages() {
- Header header = new Header("sendToEndpointUri", "natsNoAuth:max");
+ Header header = new Header("sendToEndpointUri", "natsNoAuth:max?traceConnection=true");
for (int msgNumber = 1; msgNumber <= 10; msgNumber++) {
given().when().header(header).body("msg " + msgNumber).post("/nats/send").then().statusCode(204);
}
@@ -106,7 +107,7 @@ class NatsTest {
@Test
void consumeMaxQueueMessagesShouldRetainRightNumberOfMessages() {
- Header header = new Header("sendToEndpointUri", "natsNoAuth:qmax");
+ Header header = new Header("sendToEndpointUri", "natsNoAuth:qmax?traceConnection=true");
for (int msgNumber = 1; msgNumber <= 20; msgNumber++) {
given().when().header(header).body("qmsg " + msgNumber).post("/nats/send").then().statusCode(204);
}
@@ -119,7 +120,7 @@ class NatsTest {
@Test
void requestReplyShouldSucceed() {
- Header header = new Header("sendToEndpointUri", "natsNoAuth:request-reply?replySubject=reply");
+ Header header = new Header("sendToEndpointUri", "natsNoAuth:request-reply?replySubject=reply&traceConnection=true");
given().when().header(header).body("Request").post("/nats/send").then().statusCode(204);
await().atMost(10L, TimeUnit.SECONDS).until(() -> {