-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Add Reactive TX Manager support #3201
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
Add Reactive TX Manager support #3201
Conversation
The feature is ready, but I'd like to have a real test against reactive transaction. Thanks |
4d7008e
to
acd996c
Compare
I decided to go ahead without testing MongoDB reactive transaction. The support is too involved: we need the latest MongoDB server with replica enabled. Plus we need include the replica key from the server into a connection string. |
Sorry hit single comment instead of start review; still reviewing. |
...rc/main/java/org/springframework/integration/transaction/TransactionHandleMessageAdvice.java
Show resolved
Hide resolved
...n-core/src/main/java/org/springframework/integration/config/ConsumerEndpointFactoryBean.java
Outdated
Show resolved
Hide resolved
* Change `TransactionInterceptorBuilder` and `TransactionHandleMessageAdvice` to reply on a generic `TransactionManager`, so we can configure reactive one as well * Change a `<transactional>` XML element to support a generic `TransactionManager` reference, so we can configure reactive one as well * Support `adviceChain` configuration for the `ReactiveMessageHandler` in the `ConsumerEndpointFactoryBean` * Attemp to apply reactive transaction for the Reactive MongoDB channel adapter
to support transactions we need the latest MongoDb server with replica enabled * Document reactive transactions
acd996c
to
bdb29d8
Compare
TransactionInterceptorBuilder
andTransactionHandleMessageAdvice
to replyon a generic
TransactionManager
, so we can configure reactive one as well<transactional>
XML element to support a genericTransactionManager
reference,so we can configure reactive one as well
adviceChain
configuration for theReactiveMessageHandler
in theConsumerEndpointFactoryBean