Skip to content

Commit 43335a5

Browse files
author
Daniel Bustamante Ospina
committed
Setup travis config to run integration test with rabbit and java 11
Fixes: gh-7
1 parent 6e5d08b commit 43335a5

File tree

2 files changed

+17
-1
lines changed

2 files changed

+17
-1
lines changed

README.md

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,22 @@ Don't forget to add the implementation dependency to the main spring boot module
131131
}
132132
```
133133

134+
### Request-Reply
135+
Example Code:
136+
137+
```java
138+
public Mono<AggregateResponse> queryInformation() {
139+
AsyncQuery<String> userQuery = new AsyncQuery<>("user.byId", "42");
140+
AsyncQuery<String> projectQuery = new AsyncQuery<>("project.byId", "343");
141+
AsyncQuery<String> productQuery = new AsyncQuery<>("product.byId", "22");
142+
143+
Mono<User> user = gateway.requestReply(userQuery, "Users", User.class);
144+
Mono<Project> project = gateway.requestReply(projectQuery, "Projects", Project.class);
145+
Mono<Product> product = gateway.requestReply(productQuery, "Products", Product.class);
146+
147+
return zip(user, project, product).map(function(this::aggregate));
148+
}
149+
```
134150

135151

136152
## Disclaimer

gradle.properties

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

0 commit comments

Comments
 (0)