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.

Sign up for GitHub

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

Jump to bottom

Streaming query #2001

Merged
merged 41 commits into from
Mar 24, 2022
Merged

Streaming query #2001

merged 41 commits into from
Mar 24, 2022

Commits on Oct 21, 2021

  1. Streaming Query initial sketch: 

    - streaming fluxes, lists, streams, single results, completable futures
- blocking a flux stream when invoked with multipleInstancesOf
    @m1l4n54v1c
    m1l4n54v1c committed Oct 21, 2021
    Configuration menu
    Copy the full SHA
    5380e38 View commit details
    Browse the repository at this point in the history

  2. Tests for streamingQuery

    @schananas
    schananas committed Oct 21, 2021
    Configuration menu
    Copy the full SHA
    8381c32 View commit details
    Browse the repository at this point in the history

  3. Tests for streamingQuery & refactoring

    @schananas
    schananas committed Oct 21, 2021
    Configuration menu
    Copy the full SHA
    cfad312 View commit details
    Browse the repository at this point in the history

Commits on Oct 22, 2021

  1. Implementation of streamingQuery

    @schananas
    schananas committed Oct 22, 2021
    Configuration menu
    Copy the full SHA
    e3d0e03 View commit details
    Browse the repository at this point in the history

Commits on Oct 25, 2021

  1. Making Streaming Query part of regular query. It is distinguished by … 

    …the response type.
    @m1l4n54v1c
    m1l4n54v1c committed Oct 25, 2021
    Configuration menu
    Copy the full SHA
    3ce3f69 View commit details
    Browse the repository at this point in the history

Commits on Oct 28, 2021

  1. Dispose a subscription once a receiver completes the query.

    @m1l4n54v1c
    m1l4n54v1c committed Oct 28, 2021
    Configuration menu
    Copy the full SHA
    01d61bc View commit details
    Browse the repository at this point in the history

Commits on Nov 2, 2021

  1. Add custom subscriber that reacts on flow control instructions

    @schananas
    schananas committed Nov 2, 2021
    Configuration menu
    Copy the full SHA
    60b06e4 View commit details
    Browse the repository at this point in the history

Commits on Nov 5, 2021

  1. Adjust flow control from AxonServerQueryBus

    @schananas
    schananas committed Nov 5, 2021
    Configuration menu
    Copy the full SHA
    0889b1b View commit details
    Browse the repository at this point in the history

Commits on Nov 8, 2021

  1. Add streaming query API to query gateway

    @schananas
    schananas committed Nov 8, 2021
    Configuration menu
    Copy the full SHA
    3bbee02 View commit details
    Browse the repository at this point in the history

  2. Query gateway test for streaming query

    @schananas
    schananas committed Nov 8, 2021
    Configuration menu
    Copy the full SHA
    a1f2f32 View commit details
    Browse the repository at this point in the history

Commits on Nov 9, 2021

  1. Query gateway test for streaming query

    @schananas
    schananas committed Nov 9, 2021
    Configuration menu
    Copy the full SHA
    f36a147 View commit details
    Browse the repository at this point in the history

  2. Clean up

    @schananas
    schananas committed Nov 9, 2021
    Configuration menu
    Copy the full SHA
    c212e2a View commit details
    Browse the repository at this point in the history

Commits on Nov 10, 2021

  1. Clean up on stream complete

    @schananas
    schananas committed Nov 10, 2021
    Configuration menu
    Copy the full SHA
    198dbfe View commit details
    Browse the repository at this point in the history

  2. Clean up on stream complete

    @schananas
    schananas committed Nov 10, 2021
    Configuration menu
    Copy the full SHA
    8b6af75 View commit details
    Browse the repository at this point in the history

Commits on Nov 11, 2021

  1. onError should send a query response with error.

    @m1l4n54v1c
    m1l4n54v1c committed Nov 11, 2021
    Configuration menu
    Copy the full SHA
    d976723 View commit details
    Browse the repository at this point in the history

Commits on Nov 17, 2021

  1. Return Publisher instead of Flux for backwards compatability 

    If Project Reactor is on class path and return type is MultipleInstancesResponseType then stream results under the hood and collect them to the list
    @schananas
    schananas committed Nov 17, 2021
    Configuration menu
    Copy the full SHA
    578f181 View commit details
    Browse the repository at this point in the history

  2. Merge branch 'streaming-query' of https://github.com/AxonFramework/Ax… 

    …onFramework into streaming-query
    @schananas
    schananas committed Nov 17, 2021
    Configuration menu
    Copy the full SHA
    029c693 View commit details
    Browse the repository at this point in the history

Commits on Feb 4, 2022

  1. streaming query

    @m1l4n54v1c
    m1l4n54v1c committed Feb 4, 2022
    Configuration menu
    Copy the full SHA
    0df7a33 View commit details
    Browse the repository at this point in the history

Commits on Feb 11, 2022

  1. WIP: added additional method for streaming query.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    3385504 View commit details
    Browse the repository at this point in the history

  2. Streaming query - QueryGateway

    @schananas
    schananas committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    56c92da View commit details
    Browse the repository at this point in the history

  3. Switch handler on error

    @schananas
    schananas committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    0b505b5 View commit details
    Browse the repository at this point in the history

Commits on Feb 14, 2022

  1. Added backwards compatibility tests.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    697b95d View commit details
    Browse the repository at this point in the history

  2. Added JavaDoc.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    bb610af View commit details
    Browse the repository at this point in the history

  3. Added JavaDoc to BlockingQueryResponseProcessingTask.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    bba17c4 View commit details
    Browse the repository at this point in the history

  4. Added JavaDoc to PrioritizedRunnable.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    579748b View commit details
    Browse the repository at this point in the history

  5. Switched to package private visibility of PrioritizedRunnable.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    f7d38b6 View commit details
    Browse the repository at this point in the history

  6. More JavaDoc and cleanup.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    eaf8bfa View commit details
    Browse the repository at this point in the history

  7. Merge branch 'master' 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
    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    8813d91 View commit details
    Browse the repository at this point in the history

  8. Fixed versions and merged main branch.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 14, 2022
    Configuration menu
    Copy the full SHA
    09f97f6 View commit details
    Browse the repository at this point in the history

Commits on Feb 23, 2022

  1. Disabled possibility to stream query results via regular query.

    @m1l4n54v1c
    m1l4n54v1c committed Feb 23, 2022
    Configuration menu
    Copy the full SHA
    dd4a52b View commit details
    Browse the repository at this point in the history

Commits on Mar 1, 2022

  1. code review: api changes.

    @m1l4n54v1c
    m1l4n54v1c committed Mar 1, 2022
    Configuration menu
    Copy the full SHA
    d758d0e View commit details
    Browse the repository at this point in the history

Commits on Mar 9, 2022

  1. - handled the case of cancelling streamable result before result is r… 

    …eady.

- graceful cancelling of queries in progress.
    @m1l4n54v1c
    m1l4n54v1c committed Mar 9, 2022
    Configuration menu
    Copy the full SHA
    97c4129 View commit details
    Browse the repository at this point in the history

Commits on Mar 21, 2022

  1. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/BlockingQueryResponseProcessingTask.java


JavaDoc fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    b823c06 View commit details
    Browse the repository at this point in the history

  2. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/AxonServerQueryBus.java


Error message fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    b9b25dc View commit details
    Browse the repository at this point in the history

  3. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/AxonServerQueryBus.java


Error message fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    1f3b320 View commit details
    Browse the repository at this point in the history

  4. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/AxonServerQueryBus.java


Error message fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    c9c17c9 View commit details
    Browse the repository at this point in the history

  5. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/PrioritizedRunnable.java


JavaDoc fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    fd1be4c View commit details
    Browse the repository at this point in the history

  6. Update axon-server-connector/src/main/java/org/axonframework/axonserv… 

    …er/connector/query/PrioritizedRunnable.java


JavaDoc fix.

Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
    @m1l4n54v1c @smcvb
    m1l4n54v1c and smcvb committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    b003ac6 View commit details
    Browse the repository at this point in the history

  7. - review comments.

    @m1l4n54v1c
    m1l4n54v1c committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    6e6faba View commit details
    Browse the repository at this point in the history

  8. Merge remote-tracking branch 'origin/streaming-query' into streaming-… 

    …query
    @m1l4n54v1c
    m1l4n54v1c committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    10685d4 View commit details
    Browse the repository at this point in the history

Commits on Mar 24, 2022

  1. Adapted to the latest API changes. 

    Review comments.
    @m1l4n54v1c
    m1l4n54v1c committed Mar 24, 2022
    Configuration menu
    Copy the full SHA
    279a585 View commit details
    Browse the repository at this point in the history