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); + } } }