From ce3ac36dcd7d5b7372e7091f0248ebd62a2b07d3 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 13 Nov 2018 10:34:53 -0500 Subject: [PATCH] INT-4552: UDP: Catch and log async send exceptions JIRA: https://jira.spring.io/browse/INT-4552 **Cherry-pick to 5.0.x** --- .../ip/udp/UnicastReceivingChannelAdapter.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastReceivingChannelAdapter.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastReceivingChannelAdapter.java index 1040d90843..0414a386bc 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastReceivingChannelAdapter.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastReceivingChannelAdapter.java @@ -139,7 +139,7 @@ public class UnicastReceivingChannelAdapter extends AbstractInternetProtocolRece throw new MessagingException("failed to receive DatagramPacket", e); } } - this.setListening(false); + setListening(false); } protected void sendAck(Message message) { @@ -203,7 +203,12 @@ public class UnicastReceivingChannelAdapter extends AbstractInternetProtocolRece if (message.getHeaders().containsKey(IpHeaders.ACK_ADDRESS)) { sendAck(message); } - sendMessage(message); + try { + sendMessage(message); + } + catch (Exception e) { + this.logger.error("Failed to send message " + message, e); + } } }