-
Notifications
You must be signed in to change notification settings - Fork 7
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.
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
feat: delete queues cleanup #100
Conversation
1b95716
to
35f68b7
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The classes that you changed or created if It is possible to change to "sealed"
src/KafkaFlow.Retry/Durable/Polling/Jobs/CleanupJobDataProvider.cs
Outdated
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Repository/Actions/Delete/DeleteQueuesInput.cs
Outdated
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Repository/Actions/Delete/DeleteQueuesResult.cs
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please note that some APIs suffered breaking changes on this pull request. We can and we should do them, but we should also pull the major version to 2.0.0.
samples/KafkaFlow.Retry.Sample/Helpers/KafkaClusterConfigurationBuilderHelper.cs
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Definitions/Builders/Polling/PollingDefinitionBuilder.cs
Outdated
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Definitions/Builders/Polling/PollingDefinitionsAggregatorBuilder.cs
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Definitions/Builders/Polling/PollingDefinitionsAggregatorBuilder.cs
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Definitions/Builders/Polling/PollingDefinitionsAggregatorBuilder.cs
Show resolved
Hide resolved
src/KafkaFlow.Retry/Durable/Polling/Jobs/RetryDurablePollingJob.cs
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just a small detail to solve. I'll approved after it's fixed 👌
src/KafkaFlow.Retry/Durable/Definitions/Builders/Polling/PollingDefinitionsAggregatorBuilder.cs
Show resolved
Hide resolved
...KafkaFlow.Retry/Durable/Definitions/Builders/Polling/RetryDurablePollingDefinitionBuilder.cs
Show resolved
Hide resolved
This reverts commit 86daad2.
Description
Create a retention policy for all queues and messages
Fixes #18
How Has This Been Tested?
Please describe the tests that you ran to verify your changes.
Checklist
Disclaimer
By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement