2017-07-25 6 views
0

J'utilise les observables rxjava (v 1.1.8) dans mon application de cadre de jeu (avec akka). J'aimerais savoir s'il existe un moyen de propager les informations MDC vers les Observables rxjava. Je ne vois pas d'informations MDC dans mes instructions de journal qui sont imprimées dans Observable/Subscriber. Je comprends que rxJava utilise un pool de threads séparé et qu'il doit y avoir un mécanisme pour copier les informations MDC des threads akka dans les threads rxjava. Y a-t-il une solution pour cela?Propagation de slf4j MDC (contexte de diagnostic mappé) dans rxjava Observables

Pour votre information, au sein Comme vous le voyez dans la documentation de cannelle à votre lien AKKA acteurs J'atteindre la propagation du MDC à l'aide de plug-in cannelle lightbends (http://developer.lightbend.com/docs/monitoring/latest/extensions/mdc.html)

Répondre

0

, le MDC est effectivement propagée avec le message. Il n'y a pas de concept d'identité équivalent dans RxJava. D'autre part, vous êtes libre de définir le planificateur utilisé pour les opérations RxJava et de lier le MDC au thread contrôlé par ce planificateur.