Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -20,11 +20,16 @@ public RabbitMessagePublisher(RabbitMqProperties properties, RabbitTemplate rabb
}

public <T> MessageEnvelope<T> publishToAi(String routingKey, T payload, MessageContext context) {
String traceId = TraceContext.getTraceId();
if (traceId == null || traceId.isBlank()) {
// RabbitListener / EventListener 등에서 MDC 미주입 흐름 — 발행 시점에 새 traceId 생성.
traceId = UUID.randomUUID().toString();
}
MessageEnvelope<T> envelope = new MessageEnvelope<>(
UUID.randomUUID().toString(),
routingKey,
properties.version(),
TraceContext.getTraceId(),
traceId,
Instant.now(),
properties.publisher(),
payload,
Expand Down