@ -287,7 +287,7 @@ public class AutowiredAnnotationBeanPostProcessor implements SmartInstantiationA
@@ -287,7 +287,7 @@ public class AutowiredAnnotationBeanPostProcessor implements SmartInstantiationA
@ -349,9 +349,9 @@ public class ReflectivePropertyAccessor implements PropertyAccessor {
@@ -349,9 +349,9 @@ public class ReflectivePropertyAccessor implements PropertyAccessor {
@ -410,7 +410,7 @@ public class SingleConnectionFactory implements ConnectionFactory, QueueConnecti
@@ -410,7 +410,7 @@ public class SingleConnectionFactory implements ConnectionFactory, QueueConnecti
}
// Create new (method local) connection, which is later assigned to instance connection
// - prevention to hold instance connection without exception listener, in case when
// some subsequent methods (after creation of connection) throws JMSException
// some subsequent methods (after creation of connection) throw JMSException
Connectioncon=doCreateConnection();
try{
prepareConnection(con);
@ -422,9 +422,7 @@ public class SingleConnectionFactory implements ConnectionFactory, QueueConnecti
@@ -422,9 +422,7 @@ public class SingleConnectionFactory implements ConnectionFactory, QueueConnecti
con.close();
}
catch(Throwableth){
if(logger.isDebugEnabled()){
logger.debug("Could not close newly obtained JMS Connection that failed to prepare",th);
}
logger.debug("Could not close newly obtained JMS Connection that failed to prepare",th);
@ -360,7 +360,7 @@ public class PersistenceAnnotationBeanPostProcessor implements InstantiationAwar
@@ -360,7 +360,7 @@ public class PersistenceAnnotationBeanPostProcessor implements InstantiationAwar
@ -445,7 +445,7 @@ public abstract class AbstractReactiveTransactionManager implements ReactiveTran
@@ -445,7 +445,7 @@ public abstract class AbstractReactiveTransactionManager implements ReactiveTran
returndoCommit(synchronizationManager,status);
}
returnMono.empty();
}))//
}))
.onErrorResume(ex->{
Mono<Void>propagateException=Mono.error(ex);
// Store result in a local variable in order to appease the