Skip to content

FluxMessageChannel: propagate the current context from producer to consumer #8889

Closed
@artembilan

Description

@artembilan

There is no connection between producer (FluxMessageChannel.send()) and consumer FluxMessageChannel.subscribe(Subscriber) to propagate the context (typically thread local variables), e.g. an Observation or an Authentication.
Therefore we need to look into mechanism to transport the context via IntegrationMessageHeaderAccessor.REACTOR_CONTEXT message header.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions