diff --git a/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java b/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java index 8ccf34a60e..35924dd6b1 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java @@ -38,9 +38,9 @@ import org.springframework.messaging.core.GenericMessagingTemplate; public class MessagingTemplate extends GenericMessagingTemplate { private BeanFactory beanFactory; - + private volatile boolean throwExceptionOnLateReplySet; - + /** * Create a MessagingTemplate with no default channel. Note, that one * may be provided by invoking {@link #setDefaultChannel(MessageChannel)}. @@ -61,7 +61,7 @@ public class MessagingTemplate extends GenericMessagingTemplate { */ @Override public void setBeanFactory(BeanFactory beanFactory) throws BeansException { - this.beanFactory = beanFactory; + this.beanFactory = beanFactory;//NOSONAR - non-sync is ok here super.setDestinationResolver(new BeanFactoryChannelResolver(beanFactory)); } @@ -85,7 +85,7 @@ public class MessagingTemplate extends GenericMessagingTemplate { if (!this.throwExceptionOnLateReplySet) { synchronized (this) { if (!this.throwExceptionOnLateReplySet) { - Properties integrationProperties = + Properties integrationProperties = IntegrationContextUtils.getIntegrationProperties(this.beanFactory); Boolean throwExceptionOnLateReply = Boolean.valueOf(integrationProperties .getProperty(IntegrationProperties.THROW_EXCEPTION_ON_LATE_REPLY)); diff --git a/spring-integration-core/src/main/java/org/springframework/integration/support/management/ExponentialMovingAverage.java b/spring-integration-core/src/main/java/org/springframework/integration/support/management/ExponentialMovingAverage.java index 87b0bda91c..5a4bbcf4e9 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/support/management/ExponentialMovingAverage.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/support/management/ExponentialMovingAverage.java @@ -129,7 +129,7 @@ public class ExponentialMovingAverage { double mean = weight > 0 ? sum / weight : 0.; double var = weight > 0 ? sumSquares / weight - mean * mean : 0.; double standardDeviation = var > 0 ? Math.sqrt(var) : 0; - return new Statistics(count, min == Double.MAX_VALUE ? 0 : min, max, mean, standardDeviation); + return new Statistics(count, min == Double.MAX_VALUE ? 0 : min, max, mean, standardDeviation);//NOSONAR } /**