-
Notifications
You must be signed in to change notification settings - Fork 40
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
Feature : Blocked entries methods #338
base: master
Are you sure you want to change the base?
Conversation
fix: read only queries does not need select for update
transactionoutbox-core/src/main/java/com/gruelbox/transactionoutbox/TransactionOutboxImpl.java
Show resolved
Hide resolved
...box-core/src/test/java/com/gruelbox/transactionoutbox/acceptance/AbstractAcceptanceTest.java
Outdated
Show resolved
Hide resolved
+ ALL_FIELDS | ||
+ " FROM " | ||
+ tableName | ||
+ " WHERE blocked = true AND processed = false ORDER BY lastAttemptTime DESC LIMIT ? OFFSET ?")) { |
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.
This needs to be updated to handle different dialects (LIMIT
isn't supported by Oracle).
Sorry @RomainWilbert; I got around to re-checking this PR after the Oracle PR was merged.
* .uniqueRequestId("my-request") | ||
* .schedule(MyService.class) | ||
* .runMyMethod("with", "some", "arguments");</pre> | ||
* <pre> |
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.
Lost formatting here
I added 2 methods in TransactionOutbox :
This could be usefull to create a retry screen for blocked entries