SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix logging levels

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-07-25 15:08:55 +02:00
parent 416875b9f0
commit a8ee1cc9ab
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
View File

@@ -248,7 +248,7 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl
@SuppressWarnings("unchecked")
private <T> Binder<T, ConsumerProperties, ProducerProperties> getBinderInstance(String configurationName) {
if (!this.binderInstanceCache.containsKey(configurationName)) {
logger.info("Creating binder: " + configurationName);
logger.debug("Creating binder: " + configurationName);
BinderConfiguration binderConfiguration = this.binderConfigurations
.get(configurationName);
Assert.state(binderConfiguration != null,
@@ -291,11 +291,11 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl
binderProducingContext);
}
}
logger.info("Caching the binder: " + configurationName);
logger.debug("Caching the binder: " + configurationName);
this.binderInstanceCache.put(configurationName,
new SimpleImmutableEntry<>(binder, binderProducingContext));
}
logger.info("Retrieving cached binder: " + configurationName);
logger.debug("Retrieving cached binder: " + configurationName);
return (Binder<T, ConsumerProperties, ProducerProperties>) this.binderInstanceCache
.get(configurationName).getKey();
}