update ut

JoeCqupt · Nov 5, 2024 · d696eee · d696eee
1 parent 9f99d14
commit d696eee
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/test/java/io/github/xinfra/lab/remoting/connection/ClientConnectionManagerTest.java b/src/test/java/io/github/xinfra/lab/remoting/connection/ClientConnectionManagerTest.java
@@ -281,6 +281,15 @@ void testDisableReconnect() throws InterruptedException, TimeoutException {
 
 	@Test
 	void testConnectionEventListener() throws RemotingException, InterruptedException, TimeoutException {
+
+		connectionManager.connectionEventProcessor().addConnectionEventListener(new ConnectionEventListener() {
+			@Override
+			public void onEvent(ConnectionEvent connectionEvent, Connection connection) {
+				// threw exception will not affect others listener
+				throw new RuntimeException("test throw exception");
+			}
+		});
+
 		AtomicBoolean connectFlag = new AtomicBoolean(false);
 		AtomicReference<Connection> connectionRef1 = new AtomicReference<>();
 		connectionManager.connectionEventProcessor().addConnectionEventListener(new ConnectionEventListener() {