Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add missing log guard to ReactiveCqlTemplate.

Browse Source 
Closes #1235
This commit is contained in:
Sam Lightfoot
2022-02-24 09:13:01 +00:00
committed by Mark Paluch
parent fba813b27e
commit 01629f5ab5
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplate.java
View File

@@ -469,7 +469,9 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
return createFlux(session -> {
logger.debug(String.format("Preparing statement [%s] using %s", toCql(psc), psc));
if (logger.isDebugEnabled()) {
logger.debug(String.format("Preparing statement [%s] using %s", toCql(psc), psc));
}
return psc.createPreparedStatement(session).flatMapMany(ps -> action.doInPreparedStatement(session, ps));
}).onErrorMap(translateException("ReactivePreparedStatementCallback", toCql(psc)));