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

Fix sonar smell in the MessagingGatewaySupport

Browse Source
This commit is contained in:
abilan
2023-03-17 14:52:41 -04:00
parent db90e68ca7
commit f2b88b4c6a
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-integration-core/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java
View File

@@ -589,19 +589,18 @@ public abstract class MessagingGatewaySupport extends AbstractEndpoint
} }
} }
@Nullable
private Message<?> sendAndReceiveWithObservation(MessageChannel requestChannel, Object object, private Message<?> sendAndReceiveWithObservation(MessageChannel requestChannel, Object object,
Message<?> requestMessage) { Message<?> requestMessage) {
MessageRequestReplyReceiverContext context =
new MessageRequestReplyReceiverContext(requestMessage, getComponentName());
return IntegrationObservation.GATEWAY.observation(this.observationConvention, return IntegrationObservation.GATEWAY.observation(this.observationConvention,
DefaultMessageRequestReplyReceiverObservationConvention.INSTANCE, DefaultMessageRequestReplyReceiverObservationConvention.INSTANCE,
() -> context, this.observationRegistry) () -> new MessageRequestReplyReceiverContext(requestMessage, getComponentName()),
.observe(() -> { this.observationRegistry)
.<MessageRequestReplyReceiverContext, Message<?>>observeWithContext((ctx) -> {
Message<?> replyMessage = doSendAndReceive(requestChannel, object, requestMessage); Message<?> replyMessage = doSendAndReceive(requestChannel, object, requestMessage);
if (replyMessage != null) { if (replyMessage != null) {
context.setResponse(replyMessage); ctx.setResponse(replyMessage);
} }
return replyMessage; return replyMessage;
}); });