Skip to content

Commit ed89cef

Browse files
author
Daniel Bustamante Ospina
committed
Use MessageConverter in replyListener (Fix)
1 parent 3930b2c commit ed89cef

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

async/async-commons/src/main/java/org/reactivecommons/async/impl/RabbitDirectAsyncGateway.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public <T, R> Mono<R> requestReply(AsyncQuery<T> query, String targetName, Class
4646

4747
final Mono<R> replyHolder = router.register(correlationID)
4848
.timeout(Duration.ofSeconds(15))
49-
.flatMap(s -> fromCallable(() -> (R)converter.readAsyncQuery(s, type)));
49+
.flatMap(s -> fromCallable(() -> (R)converter.readValue(s, type)));
5050

5151
Map<String, Object> headers = new HashMap<>();
5252
headers.put(REPLY_ID, config.getRoutingKey());

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
version=0.0.5-beta1
1+
version=0.0.5-beta2
22
springBootVersion=2.1.1.RELEASE

0 commit comments

Comments
 (0)