Skip to content
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

Fix in ConsumerBase.java to return failed future - #249 #257

Merged
merged 1 commit into from
Mar 1, 2017

Conversation

jai1
Copy link
Contributor

@jai1 jai1 commented Mar 1, 2017

Motivation

Fix for Issue #249

Modifications

Added return statements

Result

Failed futures will be returned if the consumer is not ready

Copy link
Contributor

@merlimat merlimat left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Change looks good, can you also add a quick unit test to verify these results?

@jai1
Copy link
Contributor Author

jai1 commented Mar 1, 2017

Added tests - can i get a +1 please

Copy link
Contributor

@merlimat merlimat left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

👍

@merlimat merlimat added the type/bug The PR fixed a bug or issue reported a bug label Mar 1, 2017
@merlimat merlimat added this to the 1.17 milestone Mar 1, 2017
@merlimat merlimat merged commit 24c7724 into apache:master Mar 1, 2017
@jai1 jai1 deleted the FixForIssue249 branch March 6, 2017 17:42
sijie added a commit to sijie/pulsar that referenced this pull request Mar 4, 2018
hrsakai pushed a commit to hrsakai/pulsar that referenced this pull request Dec 10, 2020
Signed-off-by: jonyhy96 <[email protected]>

Fixes apache#257

### Motivation

Once the connection is closed the reconnectToBroker logic of both producer and consumer will try to reconnect to the broker infinatly.

### Modifications

Add a field in the Options represent the max number of retries and not break current behavior if this field is not fullfilled.
hangc0276 pushed a commit to hangc0276/pulsar that referenced this pull request May 26, 2021
eolivelli added a commit to eolivelli/pulsar that referenced this pull request May 14, 2024
eolivelli added a commit to eolivelli/pulsar that referenced this pull request May 14, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants