Skip to content

Framework level graceful shutdown based on pausable channels#3460

Open
ozangunalp wants to merge 7 commits into
smallrye:mainfrom
ozangunalp:pausable-channel-drain
Open

Framework level graceful shutdown based on pausable channels#3460
ozangunalp wants to merge 7 commits into
smallrye:mainfrom
ozangunalp:pausable-channel-drain

Conversation

@ozangunalp

Copy link
Copy Markdown
Collaborator

WIP for now, on top of #3454

@ozangunalp ozangunalp force-pushed the pausable-channel-drain branch from a6bc58f to a047e11 Compare June 26, 2026 13:46
@codecov

codecov Bot commented Jun 26, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 74.69880% with 42 lines in your changes missing coverage. Please review.
✅ Project coverage is 77.68%. Comparing base (a96442f) to head (a047e11).
⚠️ Report is 1207 commits behind head on main.

Files with missing lines Patch % Lines
.../providers/extension/PausableChannelDecorator.java 66.66% 19 Missing and 3 partials ⚠️
...ve/messaging/kafka/impl/ReactiveKafkaConsumer.java 50.00% 2 Missing and 2 partials ⚠️
...o/smallrye/reactive/messaging/PausableChannel.java 0.00% 3 Missing ⚠️
...allrye/reactive/messaging/SubscriberDecorator.java 0.00% 2 Missing ⚠️
...tive/messaging/kafka/commit/KafkaLatestCommit.java 91.66% 2 Missing ⚠️
...ive/messaging/kafka/impl/OrderedStreamHandler.java 0.00% 2 Missing ⚠️
...roviders/extension/GracefulShutdownController.java 80.00% 2 Missing ⚠️
...ye/reactive/messaging/providers/wiring/Wiring.java 80.00% 0 Missing and 2 partials ⚠️
...o/smallrye/reactive/messaging/ChannelRegistry.java 0.00% 1 Missing ⚠️
...mallrye/reactive/messaging/PublisherDecorator.java 0.00% 1 Missing ⚠️
... and 1 more
Additional details and impacted files

Impacted file tree graph

@@             Coverage Diff              @@
##               main    #3460      +/-   ##
============================================
+ Coverage     77.47%   77.68%   +0.21%     
- Complexity     3778     5589    +1811     
============================================
  Files           306      487     +181     
  Lines         12673    18755    +6082     
  Branches       1648     2307     +659     
============================================
+ Hits           9818    14570    +4752     
- Misses         2116     3039     +923     
- Partials        739     1146     +407     
Files with missing lines Coverage Δ
...active/messaging/PausableChannelConfiguration.java 0.00% <ø> (ø)
...ye/reactive/messaging/jms/fault/JmsDlqFailure.java 92.45% <100.00%> (ø)
.../messaging/kafka/commit/KafkaCheckpointCommit.java 88.03% <ø> (+2.26%) ⬆️
...ive/messaging/kafka/commit/KafkaCommitHandler.java 100.00% <100.00%> (ø)
.../messaging/kafka/commit/KafkaShareGroupCommit.java 73.68% <ø> (ø)
...ka/commit/KafkaThrottledLatestProcessedCommit.java 91.73% <100.00%> (+0.51%) ⬆️
...ve/messaging/kafka/fault/KafkaDeadLetterQueue.java 82.43% <100.00%> (-3.08%) ⬇️
.../messaging/kafka/fault/KafkaDelayedRetryTopic.java 85.97% <100.00%> (+0.71%) ⬆️
...rye/reactive/messaging/kafka/impl/KafkaSource.java 90.27% <ø> (+4.29%) ⬆️
...ctive/messaging/kafka/impl/RebalanceListeners.java 92.18% <100.00%> (+6.22%) ⬆️
... and 15 more

... and 268 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant