alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5758 Backport DBZ-5821 to the Outbox Reactive Tracer-based dispatcher.

Browse Source
This commit is contained in:
Chris Cranford 2023-02-06 14:36:57 -05:00 committed by Jiri Pechanec
parent 93220a1641
commit 885856a0f3
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-quarkus-outbox-reactive/runtime/src/main/java/io/debezium/outbox/quarkus/internal/DebeziumTracerEventDispatcher.java
View File

@ -57,17 +57,19 @@ public Uni<Void> onExportedEvent(Object incomingevent) {
.withTag(TYPE, event.getAggregateType())
.withTag(TIMESTAMP, event.getTimestamp().toString());
try (Scope outboxSpanScope = tracer.scopeManager().activate(spanBuilder.start())) {
final Span activeSpan = tracer.scopeManager().activeSpan();
final Span activeSpan = spanBuilder.start();
try (Scope outboxSpanScope = tracer.scopeManager().activate(activeSpan)) {
Tags.COMPONENT.set(activeSpan, TRACING_COMPONENT);
tracer.inject(activeSpan.context(), Format.Builtin.TEXT_MAP, exportedSpanData);
// Define the entity map-mode object using property names and values
final Map<String, Object> dataMap = getDataMapFromEvent((ExportedEvent<?, ?>) event);
final Map<String, Object> dataMap = getDataMapFromEvent(event);
dataMap.put(OutboxConstants.TRACING_SPAN_CONTEXT, exportedSpanData.export());
return persist(dataMap);
}
finally {
activeSpan.finish();
}
}
}