Skip to content

Commit 97a0cb5

Browse files
authored
Enable tracing by default (#368)
1 parent 0a6baf7 commit 97a0cb5

File tree

4 files changed

+12
-0
lines changed

4 files changed

+12
-0
lines changed

observability/README.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,8 @@ Configure the OpenTelemetry exporter in `application.properties`:
152152
----
153153
# We are using a property placeholder to be able to test this example in convenient way in a cloud environment
154154
quarkus.otel.exporter.otlp.traces.endpoint = http://${TELEMETRY_COLLECTOR_COLLECTOR_SERVICE_HOST:localhost}:4317
155+
# To enable tracing (it is disabled by default via camel-quarkus-observability-services)
156+
quarkus.otel.sdk.disabled=false
155157
----
156158

157159
NOTE: For information about other OpenTelemetry exporters, refer to the Camel Quarkus OpenTelemetry https://camel.apache.org/camel-quarkus/next/reference/extensions/opentelemetry.html#extensions-opentelemetry-usage-exporters[extension documentation].

observability/src/main/java/org/acme/observability/Routes.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,11 +36,13 @@ private void countGreeting(Exchange exchange) {
3636
@Override
3737
public void configure() throws Exception {
3838
from("platform-http:/greeting")
39+
.log("Received at greeting: ${body}")
3940
.removeHeaders("*")
4041
.process(this::countGreeting)
4142
.to("http://localhost:{{greeting-provider-app.service.port}}/greeting-provider");
4243

4344
from("platform-http:/greeting-provider")
45+
.log("Received at greeting-provider: ${body}")
4446
// Random delay to simulate latency
4547
.to("micrometer:counter:org.acme.observability.greeting-provider?tags=type=events,purpose=example")
4648
.delay(simple("${random(1000, 5000)}"))

observability/src/main/java/org/acme/observability/TimerRoute.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,19 @@
1616
*/
1717
package org.acme.observability;
1818

19+
import java.util.concurrent.atomic.AtomicInteger;
20+
1921
import org.apache.camel.builder.RouteBuilder;
2022

2123
public class TimerRoute extends RouteBuilder {
2224

25+
AtomicInteger counter = new AtomicInteger();
26+
2327
@Override
2428
public void configure() throws Exception {
2529
from("timer:greeting?delay=10000&period=10000")
30+
.setBody(exchange -> "Custom body #" + counter.incrementAndGet())
31+
.log("Generated from timer: ${body}")
2632
.bean("timerCounter", "count")
2733
.to("http://{{greeting-app.service.host}}:{{greeting-app.service.port}}/greeting");
2834
}

observability/src/main/resources/application.properties

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@ quarkus.application.name = camel-quarkus-observability
3030
# For OTLP
3131
quarkus.otel.exporter.otlp.traces.endpoint = http://${TELEMETRY_COLLECTOR_COLLECTOR_SERVICE_HOST:localhost}:4317
3232
quarkus.otel.exporter.otlp.traces.timeout = 30s
33+
# To enable tracing (it is disabled by default via camel-quarkus-observability-services)
34+
quarkus.otel.sdk.disabled=false
3335

3436
#
3537
# Camel

0 commit comments

Comments
 (0)