Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use CompleteToListeFutureAdapter in TcpOutGateway

Browse Source 
The `TcpOutboundGateway` deals internally with a `CompletableFuture`.
However, the `AbstractMessageProducingHandler` cannot handle them until `6.0`.

* Use `CompletableToListenableFutureAdapter` to produce a reply from `TcpOutboundGateway`
which can be handled properly in the `AbstractMessageProducingHandler`
This commit is contained in:
abilan
2023-01-23 11:35:23 -05:00
parent 1aef04171f
commit 070d1868e5
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/TcpOutboundGateway.java
View File

@@ -50,7 +50,7 @@ import org.springframework.messaging.MessageHandlingException;
import org.springframework.messaging.MessagingException;
import org.springframework.messaging.support.ErrorMessage;
import org.springframework.util.Assert;
import org.springframework.util.concurrent.SettableListenableFuture;
import org.springframework.util.concurrent.CompletableToListenableFutureAdapter;
/**
* TCP outbound gateway that uses a client connection factory. If the factory is configured
@@ -239,7 +239,7 @@ public class TcpOutboundGateway extends AbstractReplyProducingMessageHandler
connection.shutdownOutput();
}
if (async) {
return reply.getFuture();
return new CompletableToListenableFutureAdapter<>(reply.getFuture());
}
else {
return getReply(requestMessage, connection, connectionId, reply);
@@ -353,7 +353,7 @@ public class TcpOutboundGateway extends AbstractReplyProducingMessageHandler
}
}
if (isAsync()) {
reply.getFuture().set(message);
reply.getFuture().complete(message);
cleanUp(reply.isHaveSemaphore(), reply.getConnection(), connectionId);
}
else {
@@ -524,7 +524,7 @@ public class TcpOutboundGateway extends AbstractReplyProducingMessageHandler
return this.reply;
}
SettableListenableFuture<Message<?>> getFuture() {
CompletableFuture<Message<?>> getFuture() {
return this.future;
}