Skip to content

[#4643 | Port] AggregateBasedJpaEventStorageEngine#stream loops until StreamingCondition matching events are retrieved#4686

Merged
smcvb merged 3 commits into
axon-5.1.xfrom
port/4643
Jun 23, 2026
Merged

[#4643 | Port] AggregateBasedJpaEventStorageEngine#stream loops until StreamingCondition matching events are retrieved#4686
smcvb merged 3 commits into
axon-5.1.xfrom
port/4643

Conversation

@smcvb

@smcvb smcvb commented Jun 23, 2026

Copy link
Copy Markdown
Contributor

This pull request is a port of #4684.
This port will resolve #4643.

smcvb added 3 commits June 23, 2026 15:23
Adjust the AggregateBasedJpaEventStorageEngine#streaming to keep querying events until some match the given StreamingCondition. If we don't do this, there's a chance that the batch is empty, stalling the ContinuesMessageStream until a new event is appended. Thus, essentially blocking a consumer like the PooledStreamingEventProcessor, potentially indefinitely.

#4625

(cherry picked from commit d7284c2)
Correct @nullable marker usage

#4625

(cherry picked from commit d1ff048)
Simplify loop by using a do-while i.o. while(true)

#4643

(cherry picked from commit a101652)
@smcvb smcvb added this to the Release 5.1.2 milestone Jun 23, 2026
@smcvb smcvb self-assigned this Jun 23, 2026
@smcvb smcvb added Type: Bug Use to signal issues that describe a bug within the system. Priority 1: Must Highest priority. A release cannot be made if this issue isn’t resolved. labels Jun 23, 2026
@smcvb smcvb requested a review from a team as a code owner June 23, 2026 13:34
@smcvb smcvb added the Type: Port Use to refer to an issue or pull request that ports logic from one branch to another. label Jun 23, 2026
@smcvb smcvb requested review from hatzlj, laura-devriendt-lemon and zambrovski and removed request for a team June 23, 2026 13:34

@hjohn hjohn left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

LGTM

@hatzlj hatzlj left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

lgtm

@smcvb smcvb merged commit 96afd75 into axon-5.1.x Jun 23, 2026
9 of 10 checks passed
@smcvb smcvb deleted the port/4643 branch June 23, 2026 14:21
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Priority 1: Must Highest priority. A release cannot be made if this issue isn’t resolved. Type: Bug Use to signal issues that describe a bug within the system. Type: Port Use to refer to an issue or pull request that ports logic from one branch to another.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants