SharedSink.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-5260 Add logging to Flux operations

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-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.