FluxMap.java

Clone Tools
  • last updated a few seconds ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates
LDEV-5440 Revert some unnecessary package name changes

  1. … 464 more files in changeset.
LDEV-5440 Refactor packages of imported classes

  1. … 481 more files in changeset.
LDEV-5440 Rewrite config files and library references

  1. … 955 more files in changeset.
LDEV-5423 Complete Flux on all subscriptions terminated

Also:

* use separate and configurable task executor for async requests

* introduce backlog pressure strategy for Fluxes

* synchronise access to Flux mapping

* add logs

  1. … 3 more files in changeset.
LDEV-5260 Fix multiple timers Flux

  1. … 2 more files in changeset.
LDEV-5260 Improve subscription termination mechanism

LDEV-5260 Synchronise Flux creation

With high load there could have been multiple Fluxes with the same name and key instead of a singleton for all subscribers to this Flux.

LDEV-5260 Improve Flux backpressure and error handling

  1. … 2 more files in changeset.
LDEV-5083 Prevent WF from freezing on shutdown because of unclosed Flux

Open Fluxes prevent WF from shutting down as they are threads not

managed by the server lifecycle.

Now we force complete Sinks on Spring context destroy. It closes

underlying Flux threads.

The problem is that it occurs when most Spring beans are already

destroyed. Fluxes on close want to emit a signal to front end

subscribers. Spring tries to reinitialise controllers which should send

those signals. It fails as context basically does not exist anymore.

All in all we get some harmless errors on server shutdown.

The way to avoid would be to have more control over Spring bean destroy

order which does not seem easily achievable.

  1. … 3 more files in changeset.
LDEV-5083 Update learner progress timeline using Flux

  1. … 9 more files in changeset.
LDEV-5260 Add utility class for global Flux management

  1. … 4 more files in changeset.
LDEV-5260 Move custom Flux classes to separate package

  1. … 3 more files in changeset.