Skip to content

Commit 1e8da3a

Browse files
garyrussellartembilan
authored andcommitted
INT-4552: UDP: Catch and log async send exceptions
JIRA: https://jira.spring.io/browse/INT-4552 **Cherry-pick to 5.0.x** (cherry picked from commit ce3ac36)
1 parent 5dff882 commit 1e8da3a

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/UnicastReceivingChannelAdapter.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ public void run() {
139139
throw new MessagingException("failed to receive DatagramPacket", e);
140140
}
141141
}
142-
this.setListening(false);
142+
setListening(false);
143143
}
144144

145145
protected void sendAck(Message<byte[]> message) {
@@ -203,7 +203,12 @@ protected void doSend(final DatagramPacket packet) {
203203
if (message.getHeaders().containsKey(IpHeaders.ACK_ADDRESS)) {
204204
sendAck(message);
205205
}
206-
sendMessage(message);
206+
try {
207+
sendMessage(message);
208+
}
209+
catch (Exception e) {
210+
this.logger.error("Failed to send message " + message, e);
211+
}
207212
}
208213
}
209214

0 commit comments

Comments
 (0)