iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Real Time Event Streaming with Spring Webflux

Browse Source
This commit is contained in:
Chirag Dewan 2018-07-23 21:10:03 +05:30
parent 945932fa1d
commit f95092d90a
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketClient.java
View File

@ -10,12 +10,14 @@ import org.springframework.web.reactive.socket.client.WebSocketClient;
public class EventWebSocketClient { public class EventWebSocketClient {
private static final String REMOTE_URL = "ws://localhost:8080/events";
public static void main(String[] args) throws URISyntaxException { public static void main(String[] args) throws URISyntaxException {
WebSocketClient client = new ReactorNettyWebSocketClient(); WebSocketClient client = new ReactorNettyWebSocketClient();
client.execute( client.execute(
URI.create("ws://localhost:8080/events"), URI.create(REMOTE_URL),
session -> session.receive() session -> session.receive()
.map(WebSocketMessage::getPayloadAsText) .map(WebSocketMessage::getPayloadAsText)
.log().then()) .log().then())