diff options
Diffstat (limited to 'spring-messaging/src/main/java/org/springframework/messaging/tcp')
| -rw-r--r-- | spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/Reactor2TcpClient.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/Reactor2TcpClient.java b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/Reactor2TcpClient.java index 664e23c2..71541dcd 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/Reactor2TcpClient.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/Reactor2TcpClient.java @@ -168,7 +168,7 @@ public class Reactor2TcpClient<P> implements TcpOperations<P> { Assert.notNull(connectionHandler, "TcpConnectionHandler must not be null"); final TcpClient<Message<P>, Message<P>> tcpClient; - Runnable cleanupTask; + final Runnable cleanupTask; synchronized (this.tcpClients) { if (this.stopping) { IllegalStateException ex = new IllegalStateException("Shutting down."); @@ -194,6 +194,7 @@ public class Reactor2TcpClient<P> implements TcpOperations<P> { promise.onError(new Consumer<Throwable>() { @Override public void accept(Throwable ex) { + cleanupTask.run(); connectionHandler.afterConnectFailure(ex); } }) |