Skip to content

Commit 3b69781

Browse files
author
Daniel Bustamante Ospina
committed
Remove deprecated class
1 parent ee887d9 commit 3b69781

File tree

3 files changed

+11
-33
lines changed

3 files changed

+11
-33
lines changed

.gitignore

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
.idea
22
.gradle
33
build
4-
out
4+
out
5+
contiperf-report

async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/ReplyCommandSender.java

Lines changed: 0 additions & 28 deletions
This file was deleted.

samples/async/sender-client/src/main/java/sample/MemberRegistrySender.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,23 @@
11
package sample;
22

3+
import org.reactivecommons.async.api.AsyncQuery;
4+
import org.reactivecommons.async.api.DirectAsyncGateway;
5+
import org.springframework.beans.factory.annotation.Autowired;
36
import org.springframework.stereotype.Service;
47
import reactor.core.publisher.Mono;
5-
import org.reactivecommons.async.impl.ReplyCommandSender;
68

79
@Service
8-
public class MemberRegistrySender extends ReplyCommandSender {
10+
public class MemberRegistrySender {
911
private static final String REGISTER_MEMBER = "serveQuery.register.member";
1012

13+
@Autowired
14+
private DirectAsyncGateway asyncGateway;
15+
1116
public Mono<MemberRegisteredEvent> registerMember(AddMemberCommand command){
12-
return sendCommand(command, REGISTER_MEMBER, MemberRegisteredEvent.class);
17+
AsyncQuery<AddMemberCommand> asyncQuery = new AsyncQuery<>(REGISTER_MEMBER, command);
18+
return asyncGateway.requestReply(asyncQuery, target(), MemberRegisteredEvent.class);
1319
}
1420

15-
@Override
1621
protected String target() {
1722
return "Receiver2";
1823
}

0 commit comments

Comments
 (0)