jlengrand/quarkus
1
0
Fork 0
mirror of https://github.com/jlengrand/quarkus.git synced 2026-03-10 08:41:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve the Transactional Interceptor to handle other Publisher types

Browse Source 
Converters should also be searched for Publisher instances, or you won't be able to re-create the Publisher instance (Flux, Mono, Multi) after the async handling.
This commit is contained in:
Clement Escoffier
2020-02-20 09:02:41 +01:00
parent 2bd5d8e092
commit acca039c8a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
extensions/narayana-jta/runtime/src/main/java/io/quarkus/narayana/jta/runtime/interceptor/TransactionalInterceptorBase.java
View File

@@ -125,7 +125,7 @@ public abstract class TransactionalInterceptorBase implements Serializable {
if (!throwing && ret != null) {
ReactiveTypeConverter<Object> converter = null;
if (ret instanceof CompletionStage == false
&& ret instanceof Publisher == false) {
&& (ret instanceof Publisher == false || ic.getMethod().getReturnType() != Publisher.class)) {
@SuppressWarnings({ "rawtypes", "unchecked" })
Optional<ReactiveTypeConverter<Object>> lookup = Registry.lookup((Class) ret.getClass());
if (lookup.isPresent()) {