Skip to content

Commit eeb951b

Browse files
committed
Fix new Sonar Smells
* Change `whats-new.adoc#x5.2-behavior` to point for the whole `5.1-to-5.2-Migration-Guide`
1 parent 9994997 commit eeb951b

File tree

3 files changed

+31
-25
lines changed

3 files changed

+31
-25
lines changed

spring-integration-core/src/main/java/org/springframework/integration/channel/NullChannel.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,15 +290,14 @@ private void incrementReceiveCounter() {
290290
}
291291

292292
private CounterFacade buildReceiveCounter() {
293-
CounterFacade counterFacade = this.metricsCaptor
293+
return this.metricsCaptor
294294
.counterBuilder(RECEIVE_COUNTER_NAME)
295295
.tag("name", getComponentName() == null ? "unknown" : getComponentName())
296296
.tag("type", "channel")
297297
.tag("result", "success")
298298
.tag("exception", "none")
299299
.description("Messages received")
300300
.build();
301-
return counterFacade;
302301
}
303302

304303
@Override

spring-integration-core/src/main/java/org/springframework/integration/transaction/ExpressionEvaluatingTransactionSynchronizationProcessor.java

Lines changed: 29 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package org.springframework.integration.transaction;
1818

19+
import java.util.Map;
1920
import java.util.Map.Entry;
2021

2122
import org.springframework.expression.EvaluationContext;
@@ -142,28 +143,7 @@ private void doProcess(IntegrationResourceHolder holder, Expression expression,
142143
EvaluationContext evaluationContextToUse = prepareEvaluationContextToUse(holder);
143144
Object value = expression.getValue(evaluationContextToUse, message);
144145
if (value != null && messageChannel != null) {
145-
if (logger.isDebugEnabled()) {
146-
logger.debug("Sending expression result message to " + messageChannel + " " +
147-
"as part of '" + expressionType + "' transaction synchronization");
148-
}
149-
Message<?> spelResultMessage = null;
150-
try {
151-
if (value instanceof Message<?>) {
152-
spelResultMessage = (Message<?>) value;
153-
}
154-
else {
155-
spelResultMessage =
156-
getMessageBuilderFactory()
157-
.withPayload(value)
158-
.copyHeaders(message.getHeaders())
159-
.build();
160-
}
161-
162-
sendMessage(messageChannel, spelResultMessage);
163-
}
164-
catch (Exception e) {
165-
logger.error("Failed to send " + expressionType + " evaluation result " + spelResultMessage, e);
166-
}
146+
sendMessageForExpressionResult(value, message.getHeaders(), messageChannel, expressionType);
167147
}
168148
else {
169149
if (logger.isTraceEnabled()) {
@@ -189,6 +169,33 @@ else if (messageChannel != null) {
189169
}
190170
}
191171

172+
private void sendMessageForExpressionResult(Object value, Map<String, ?> headers,
173+
MessageChannel messageChannel, String expressionType) {
174+
175+
if (logger.isDebugEnabled()) {
176+
logger.debug("Sending expression result message to " + messageChannel + " " +
177+
"as part of '" + expressionType + "' transaction synchronization");
178+
}
179+
Message<?> spelResultMessage = null;
180+
try {
181+
if (value instanceof Message<?>) {
182+
spelResultMessage = (Message<?>) value;
183+
}
184+
else {
185+
spelResultMessage =
186+
getMessageBuilderFactory()
187+
.withPayload(value)
188+
.copyHeaders(headers)
189+
.build();
190+
}
191+
192+
sendMessage(messageChannel, spelResultMessage);
193+
}
194+
catch (Exception e) {
195+
logger.error("Failed to send " + expressionType + " evaluation result " + spelResultMessage, e);
196+
}
197+
}
198+
192199
private void sendMessage(MessageChannel channel, Message<?> message) {
193200
channel.send(message, 0);
194201
}

src/reference/asciidoc/whats-new.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ If you are interested in more details, see the Issue Tracker tickets that were r
2020
[[x5.2-behavior]]
2121
=== Behavior Changes
2222

23-
See the https://github.com/spring-projects/spring-integration/wiki/Spring-Integration-5.1-to-5.2-Migration-Guide#dsl-publishsubscribechannel-behavior-change[Migration Guide] about a behavior change when using `publishSubscribeChannel` within a dynamically registered DSL integration flow.
23+
See the https://github.com/spring-projects/spring-integration/wiki/Spring-Integration-5.1-to-5.2-Migration-Guide[Migration Guide] about behavior changes in this version.
2424

2525
[[x5.2-new-components]]
2626
=== New Components

0 commit comments

Comments
 (0)