如何对Spring WebSocketStompClient进行单元测试

import org.junit.jupiter.api.Test;
import org.springframework.messaging.simp.stomp.StompFrameHandler;
import org.springframework.messaging.simp.stomp.StompHeaders;
import import org.springframework.messaging.simp.stomp.StompSession;
import org.springframework.messaging.simp.stomp.StompSessionHandlerAdapter;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.messaging.WebSocketStompClient;

import java.lang.reflect.Type;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;

public class WebSocketStompClientTest {

    @Test
    public void testWebSocketStompClient() throws Exception {
        // 模拟WebSocket服务器
        MockWebSocketServer mockServer = new MockWebSocketServer();
        mockServer.start();

        // 创建WebSocketStompClient实例
        WebSocketStompClient stompClient = new WebSocketStompClient(new StandardWebSocketClient());

        // 设置WebSocket连接参数
        stompClient.setDefaultUri("ws://localhost:8080/ws");

        // 设置WebSocket消息处理器
        StompSessionHandlerAdapter sessionHandler = new StompSessionHandlerAdapter() {
            @Override
            public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
                // 发送消息
                session.send("/app/sendMessage", "Hello");
            }
        };
        stompClient.connect("ws://localhost:8080/ws", sessionHandler);

        // 等待消息接收完成
        mockServer.getLatch().await(10, TimeUnit.SECONDS);

        // 验证结果
        assertTrue(mockServer.getLatch().getCount() == 0);
        assertEquals("Hello", mockServer.getReceivedMessage());

        // 关闭WebSocket连接
        stompClient.stop();

        // 停止模拟WebSocket服务器
        mockServer.stop();
    }

    private static class MockWebSocketServer extends WebSocketServer {
        private CountDownLatch latch = new CountDownLatch(1);
        private String receivedMessage;

        @Override
        public void onWebSocketText(String message) {
            receivedMessage = message;
            latch.countDown();
        }

        public CountDownLatch getLatch() {
            return latch;
        }

        public String getReceivedMessage() {
            return receivedMessage;
        }
    }
}