Skip to content

Conversation

@scottf
Copy link
Contributor

@scottf scottf commented Jul 15, 2025

Also test app and example cleanup.


void initSub(NatsJetStreamPullSubscription sub) {
this.sub = sub;
this.consumerName = sub.getConsumerName();
Copy link
Contributor Author

Choose a reason for hiding this comment

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

Directly setting the consumer name.

@Override
public String getConsumerName() {
if (consumerName == null) {
if (consumerName == null && cachedConsumerInfo != null) {
Copy link
Contributor Author

Choose a reason for hiding this comment

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

found the bug when cachedConsumerInfo was null, early in the lifecycle. Fixed the problem above but added the guard anyway.

@scottf scottf requested a review from MauriceVanVeen July 15, 2025 02:05
Copy link
Member

@MauriceVanVeen MauriceVanVeen left a comment

Choose a reason for hiding this comment

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

LGTM

@scottf scottf merged commit cb2f484 into main Jul 15, 2025
5 checks passed
@scottf scottf deleted the ordered-consumer-name-argh branch July 15, 2025 11:44
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.

3 participants