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
Streaming query #2001
Streaming query #2001
Conversation
- streaming fluxes, lists, streams, single results, completable futures - blocking a flux stream when invoked with multipleInstancesOf
…the response type.
If Project Reactor is on class path and return type is MultipleInstancesResponseType then stream results under the hood and collect them to the list
…onFramework into streaming-query
# Conflicts: # axon-server-connector/src/main/java/org/axonframework/axonserver/connector/query/AxonServerQueryBus.java # axon-server-connector/src/test/java/org/axonframework/axonserver/connector/query/AxonServerQueryBusTest.java # messaging/src/main/java/org/axonframework/queryhandling/SimpleQueryBus.java # messaging/src/test/java/org/axonframework/queryhandling/SimpleQueryBusTest.java # pom.xml
…eady. - graceful cancelling of queries in progress.
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.
Too many arguments to approve this PR for. Conceptually I'm okay with the intent of the code, by the way. The comments are mainly clean-up and documentation recommendations.
...n/java/org/axonframework/axonserver/connector/query/BlockingQueryResponseProcessingTask.java
Outdated
Show resolved
Hide resolved
...connector/src/main/java/org/axonframework/axonserver/connector/query/AxonServerQueryBus.java
Outdated
Show resolved
Hide resolved
...connector/src/main/java/org/axonframework/axonserver/connector/query/AxonServerQueryBus.java
Show resolved
Hide resolved
...connector/src/main/java/org/axonframework/axonserver/connector/query/AxonServerQueryBus.java
Show resolved
Hide resolved
...connector/src/main/java/org/axonframework/axonserver/connector/query/AxonServerQueryBus.java
Outdated
Show resolved
Hide resolved
messaging/src/main/java/org/axonframework/util/ClasspathResolver.java
Outdated
Show resolved
Hide resolved
messaging/src/test/java/org/axonframework/queryhandling/DefaultQueryGatewayTest.java
Outdated
Show resolved
Hide resolved
messaging/src/test/java/org/axonframework/queryhandling/StreamingQueryTest.java
Outdated
Show resolved
Hide resolved
messaging/src/test/java/org/axonframework/queryhandling/StreamingQueryTest.java
Outdated
Show resolved
Hide resolved
messaging/src/test/java/org/axonframework/queryhandling/SimpleQueryBusTest.java
Outdated
Show resolved
Hide resolved
…er/connector/query/BlockingQueryResponseProcessingTask.java JavaDoc fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…er/connector/query/AxonServerQueryBus.java Error message fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…er/connector/query/AxonServerQueryBus.java Error message fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…er/connector/query/AxonServerQueryBus.java Error message fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…er/connector/query/PrioritizedRunnable.java JavaDoc fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…er/connector/query/PrioritizedRunnable.java JavaDoc fix. Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
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.
There are still a couple of minor JavaDoc comments open. The far majority of my feedback has been processed though. As such, I trust the rest will be dealt with accordingly. Hence, I am approving this pull request.
Review comments.
Kudos, SonarCloud Quality Gate passed! |
Adds support for streaming queries. Streaming query allows client to stream large data result sets.