Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[backport - sort of - 1.2] Prevent multiple stream processors - fix and narrow test #8101

Merged
3 commits merged into from
Nov 1, 2021
Merged

[backport - sort of - 1.2] Prevent multiple stream processors - fix and narrow test #8101

3 commits merged into from
Nov 1, 2021

Commits on Nov 1, 2021

  1. test(broker): add test for #8044

    @pihme
    pihme committed Nov 1, 2021
    Configuration menu
    Copy the full SHA
    7dae89a View commit details
    Browse the repository at this point in the history

  2. refactor(broker): always set stream processor in context 

    With this commit the stream processor is always set in the transition context, regardless of whether it could
be started successfully or not. The main benefit is that the reference to the newly created stream processor
is always stored in the context, and so it can be found there and closed.

Previously, if the opening of the stream processor failed, it was in an undefined state - potentially running
and potentially registered in ActorScheduler which holds a permanent reference to it.
    @pihme
    pihme committed Nov 1, 2021
    Configuration menu
    Copy the full SHA
    5dd5c3a View commit details
    Browse the repository at this point in the history

  3. refactor(broker): forward exceptions in transition to future

    @pihme
    pihme committed Nov 1, 2021
    Configuration menu
    Copy the full SHA
    c6cc35f View commit details
    Browse the repository at this point in the history