File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2002-2016 the original author or authors.
2
+ * Copyright 2002-2019 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
@@ -377,12 +377,14 @@ public void run() {
377
377
oos .writeObject (request .replace ("Test" , "Reply" ));
378
378
logger .debug ("Replied to " + request );
379
379
lastReceived .set (request );
380
- serverLatch .countDown ();
381
380
}
382
381
catch (IOException e ) {
383
382
logger .debug ("error on write " + e .getClass ().getSimpleName ());
384
383
socket .close ();
385
384
}
385
+ finally {
386
+ serverLatch .countDown ();
387
+ }
386
388
}
387
389
}
388
390
}
You can’t perform that action at this time.
0 commit comments