import jakarta.annotation.PostConstruct; import org.springframework.stereotype.Component; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketHttpHeaders; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.client.standard.StandardWebSocketClient; import org.springframework.web.socket.handler.TextWebSocketHandler; import java.net.URI; import java.util.concurrent.CompletableFuture; @Component public class WebSocketClient extends TextWebSocketHandler { private static final String WEBSOCKET_URI = “…………..”; private static final String SUBSCRIPTION_MESSAGE = “…………..”; @PostConstruct public void connect() { StandardWebSocketClient client = new StandardWebSocketClient(); CompletableFuture<WebSocketSession> future = client.execute(this, new WebSocketHttpHeaders(), […]