-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
[issue #3975] Bugfix NPE on non durable consumer #3988
[issue #3975] Bugfix NPE on non durable consumer #3988
Conversation
@@ -193,6 +193,7 @@ | |||
* @return the new NonDurableCursor | |||
*/ | |||
ManagedCursor newNonDurableCursor(Position startCursorPosition) throws ManagedLedgerException; | |||
ManagedCursor newNonDurableCursor(Position startPosition, String subscriptionName) throws ManagedLedgerException; |
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.
I think that the correct action here would be to modify existing newNonDurableCursor
instead of adding a new one, but I did that way in order to leave this change as easy as possible, please let me know what you think.
Hi @ConcurrencyPractitioner please take a look at this pull, you might face this issue adding tests on #3983 to |
bc74097
to
3a879ab
Compare
*Motivation* Trying to fix apache#3975 When a reset of a cursor is performed with some timestamp on a non-durable consumer the message finder will fail with null pointer exception due to `cursor.getName()` being null. *Modifications* - Add method overloading for `newNonDurableCursor()` with subscription name. - Fix method getNonDurableSubscription to call `newNonDurableCursor()` with proper subscription name - Add test to assert issue.
3a879ab
to
1434b02
Compare
run integration tests |
*Motivation* Trying to fix #3975 When a reset of a cursor is performed with some timestamp on a non-durable consumer the message finder will fail with null pointer exception due to `cursor.getName()` being null. *Modifications* - Add method overloading for `newNonDurableCursor()` with subscription name. - Fix method getNonDurableSubscription to call `newNonDurableCursor()` with proper subscription name - Add test to assert issue.
Motivation
Trying to fix #3975
When a reset of a cursor is performed with some timestamp on a non-durable
consumer the message finder will fail with null pointer exception due to
cursor.getName()
being null.Modifications
newNonDurableCursor()
with subscription name.newNonDurableCursor()
withproper subscription name
Verifying this change