Reputation: 11
I make some project use RSocket, and i refer that post, I want know where implement code send Message to other client logic.
@MessageMapping("send")
public Mono<Void> sendMessage(String p) {
return this.messages.save(new Message(p, Instant.now())).log().then();
}
@MessageMapping("messages")
public Flux<Message> messageStream() {
return this.messages.getMessageBy().log();
}
My project link I search Docs, Post... but no Information :((
Upvotes: 1
Views: 95