RabbitMQ trace

[Toxa45]

Good afternoon.
I am using org.springframework.cloud:spring-cloud-starter-stream-rabbit , can you tell me how to enable traceId logging for rabbitMQ? Otherwise, when processing a message in the logs, I see TID=N/A and there is no tracing in skywalking.

[Toxa45]

An example of a listener that does not log traceId

@Slf4j
@Configuration
@RequiredArgsConstructor
public class MessageListener {
    private final MessageProcessor messageProcessor;
    @Bean 
    public Consumer<StatusChangedData> statusChanged() {
        return messageProcessor::statusChanged;
    }
}

@Slf4j
@Service
@RequiredArgsConstructor
@Validated
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
public class MessageProcessor {
		
		public void statusChanged(@Valid StatusChangedData event) {
			log.info("event: {}", event);
		}
}

[wu-sheng]

You could find sample codes in https://github.com/apache/skywalking-java/tree/main/test/plugin/scenarios

[wu-sheng]

If this doesn't match your case, you have to check plugin source codes on your own.

[Toxa45]

thanks, I will take a look