-
Notifications
You must be signed in to change notification settings - Fork 2
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
Persistent streams #206
Persistent streams #206
Conversation
Since this feature is intended to work in combination with Axon Framework 4.10.0, the PR should also be part of Multitenancy extension 4.10.0. |
done |
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 is some markdown in between javadoc entries and some unused imports in classes.
...framework/extensions/multitenancy/autoconfig/TenantPersistentStreamMessageSourceFactory.java
Outdated
Show resolved
Hide resolved
...ain/java/org/axonframework/extensions/multitenancy/components/MultiTenantAwareComponent.java
Outdated
Show resolved
Hide resolved
# Conflicts: # multitenancy-spring-boot-3-integrationtests/pom.xml # pom.xml
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.
I think the implementation is in line with what I expected, but there are quite some clean-up things I believe we should cover before we start merging this.
Nonetheless, great job, and thanks for the PR! 🙌
...onframework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSource.java
Show resolved
Hide resolved
...onframework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSource.java
Show resolved
Hide resolved
...onframework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSource.java
Show resolved
Hide resolved
...onframework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSource.java
Show resolved
Hide resolved
...rg/axonframework/extensions/multitenancy/configuration/MultiTenantEventProcessingModule.java
Outdated
Show resolved
Hide resolved
...amework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamAutoConfiguration.java
Show resolved
Hide resolved
...amework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSourceTest.java
Outdated
Show resolved
Hide resolved
...onframework/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamMessageSource.java
Show resolved
Hide resolved
…enancy/configuration/MultiTenantEventProcessingModule.java Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
…enancy/components/MultiTenantAwareComponent.java Co-authored-by: Steven van Beelen <steven.vanbeelen@axoniq.io>
@@ -62,5 +62,9 @@ | |||
<version>${mockito.version}</version> | |||
<scope>test</scope> | |||
</dependency> | |||
<dependency> |
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.
Ah, bummer, I didn't think about the dependency that would move if we'd do this...
Let's move the Persistent Stream implementing class back to the auto-configuration module.
My apologies for sending you back and forth!
Quality Gate failedFailed conditions |
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.
My concerns have been addressed, hence I'm approving this pull request.
Implementation and support for persistent streams